Исключение в потоке "main" - PullRequest
Новая
       93

Исключение в потоке "main"

0 голосов
/ 27 марта 2019

Я пытаюсь реализовать "Адаптер Pulsar для Apache Kafka" через Java, и я следую тот же документ с веб-сайта Pulsar Apache https://pulsar.apache.org/docs/en/adaptors-kafka/

Я следую примеру GitHub для реализации https://github.com/apache/pulsar/tree/master/pulsar-client-kafka-compat/pulsar-client-kafka-tests/src/test/java/org/apache/pulsar/client/kafka/compat/examples

Я добавил зависимую maven в мой файл pom.xml 

<dependency>
    <groupId>org.apache.pulsar</groupId>
    <artifactId>pulsar-client-kafka</artifactId>
    <version>2.3.0</version>
</dependency>

После успешной сборки maven тот же файл, который я поместил в целевое местоположение внутри образа докера, запустил ConsumerExample.java и ProducerExample.java в параллельном окне.

Когда я запускаю класс ProducerExample.java, я сталкиваюсь с исключением. см. ниже 

Exception in thread "main" java.lang.NoSuchMethodError: org.apache.pulsar.client.api.PulsarClient.getPartitionsForTopic(Ljava/lang/String;)Ljava/util/concurrent/CompletableFuture;
    at org.apache.kafka.clients.producer.KafkaProducer.readPartitionsInfo(KafkaProducer.java:237)
    at org.apache.kafka.clients.producer.KafkaProducer.createNewProducer(KafkaProducer.java:229)
    at org.apache.kafka.clients.producer.KafkaProducer.lambda$send$1(KafkaProducer.java:161)
    at java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1660)
    at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:161)
    at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:153)
    at pulsar_producer_consumer.pulsar_producer_consumer.ProducerExample.main(ProducerExample.java:26)

Каким было бы решение ??

...