Apache kafka NosuchErrormethod лидер () Lkafka / кластер / брокер;

Question

У меня есть сценарий, в котором я должен отправить данные через Kafka во Flink.Сейчас я использую FlinkKafka Connector.Данные успешно отправлены Брокеру производителем.Но когда я пытаюсь прочитать данные от потребителя, я получаю сообщение об ошибке.Exception : java.lang.NoSuchMethodError: kafka.javaapi.PartitionMetadata.leader()Lkafka/cluster/Broker;

Я не могу понять эту ошибку, а также я не знаю, как ее исправить.Любая помощь будет оценена.

Answer 1

Я решил эту ошибку, импортировав kafka-клиентов: 0.8.2.2

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>0.8.2.2</version>
</dependency>

Надеюсь, это поможет.