apache-kafka-streams - java.lang.NoSuchMethodError : org. kafka 流中的 apache.kafka.common.metrics.Sensor.add 错误

Question

当我尝试创建 kafka 流实例时，出现以下异常。Exception in thread "main" java.lang.NoSuchMethodError: org.apache.kafka.common.metrics.Sensor.add(Lorg/apache/kafka/common/MetricName;Lorg/apache/kafka/common/metrics/MeasurableStat;)Z
at org.apache.kafka.streams.processor.internals.metrics.StreamsMetricsImpl.<init>(StreamsMetricsImpl.java:64)
at org.apache.kafka.streams.processor.internals.StreamThread$StreamsMetricsThreadImpl.<init>(StreamThread.java:525)
at org.apache.kafka.streams.processor.internals.StreamThread.create(StreamThread.java:618)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:706)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:624)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:534)
我正在尝试在 intellij 中运行 WordCountDemo scala 示例，但无法这样做。我有 org.apache.kafka:kafka-streams-scala_2.11:2.1.0和 org.apache.kafka:kafka-clients:1.0.2我的项目中包含的依赖项，并查看导入的 jars。

Answer 1

答案已在@Matthias 的评论中找到

You will need same client version org.apache.kafka:kafka-clients:2.1.0 that matches KafkaStreams version

这被证实对提问者有效。