1

我正在尝试编写一个程序，使我能够在 Scala 中对 Kafka 主题运行预定义的 KSQL 操作，但我不想每次都打开 KSQL Cli。因此，我想从我的 Scala 程序中启动 KSQL“服务器”。如果我正确理解了 KSQL 源代码，我必须构建并启动一个 KsqlRestApplication：

def restServer = KsqlRestApplication.buildApplication(new 
KsqlRestConfig(defaultServerProperties), true, new VersionCheckerAgent 
{override def start(ksqlModuleType: KsqlModuleType, properties: 
Properties): Unit = ???})

但是当我尝试这样做时，我收到以下错误：

Exception in thread "main" java.lang.NoSuchMethodError: org.apache.kafka.streams.StreamsConfig.getConsumerConfigs(Ljava/lang/String;Ljava/lang/String;)Ljava/util/Map;
at io.confluent.ksql.rest.server.BrokerCompatibilityCheck.create(BrokerCompatibilityCheck.java:62)
at io.confluent.ksql.rest.server.KsqlRestApplication.buildApplication(KsqlRestApplication.java:241)

我查看了 BrokerCompatibilityCheck 中的函数调用，并在创建函数中调用了 StreamsConfig.getConsumerConfigs() ，并使用 2 个字符串作为参数，而不是在

https://kafka.apache.org/0102/javadoc/org/apache/kafka/streams/StreamsConfig.html#getConsumerConfigs(StreamThread,%20java.lang.String,%20java.lang.String)。

我的 KSQL 和 Kafka 版本根本不兼容还是我做错了什么？我正在使用 KSQL 版本 4.1.0-SNAPSHOT 和 Kafka 版本 1.0.0。

4

1 回答 1

3

是的，NoSuchMethodError 通常表示库之间的版本不兼容。

您发布的链接是 kafka 0.10.2 的 javadoc。该方法在 1.0 中没有改变，但在即将到来的 1.1 中确实只需要 2 个字符串： https://kafka.apache.org/11/javadoc/org/apache/kafka/streams/StreamsConfig.html#getConsumerConfigs(java. lang.String,%20java.lang.String) 。这表明您使用的 KSQL 版本（4.1.0-SNAPSHOT）取决于 kafka 流的 1.1 版本，该版本目前处于发布候选阶段，我相信并且应该很快就会发布：

https://lists.apache.org/thread.html/780c4458b16590e99261b69d7b41b9ec374a3226d72c8d38885a008a@%3Cusers.kafka.apache.org%3E

根据该电子邮件，您可以在 apache 暂存存储库中找到最新的 (1.1.0-rc2) 工件： https ://repository.apache.org/content/groups/staging/

于 2018-03-14T09:55:12.240 回答