Я получаю следующее исключение, когда пытаюсь создать экземпляр потоков 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)
Я пытаюсь запустить пример scala WordCountDemo в intellij, но не могу этого сделать.У меня есть org.apache.kafka:kafka-streams-scala_2.11:2.1.0
и org.apache.kafka:kafka-clients:1.0.2
зависимости, включенные в мой проект, и я вижу импортированные файлы.