Ash*_*try 7 apache-kafka-streams
当我尝试创建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包含在我的项目依赖进口看的罐子。
答案已经在 @Matthias 的评论中找到了
您将需要与 KafkaStreams 版本匹配的相同客户端版本 org.apache.kafka:kafka-clients:2.1.0
这被证实对提问者有效。
| 归档时间: |
|
| 查看次数: |
1441 次 |
| 最近记录: |