Выпуск Kafka Mirror Maker обновлен с 1.0.2 до 2.2.0 - Не удалось создать потребителя - Нет разрешаемых URL начальной загрузки - PullRequest
0 голосов
/ 12 мая 2019

Недавно я обновил зеркало kafka, и теперь он не может подключиться к исходным серверам zk - потребитель не работает.Предыдущая версия была основана на java: openjdk-8-jre, kafka_2.11-1.0.2.tgz и zookeeper: 3.4.10.Я обновил kafka до kafka_2.12-2.2.0.tgz, оставаясь на той же версии 3.4.10 zk и java: openjdk-8-jre.Проблема в том, что когда я запускаю зеркало kafka, теперь на 2.2.0, я получаю очень странную ошибку:

org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
        at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:90)
        at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:49)
        at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:721)
        ... 13 more

Если я переключаю зеркало kafka обратно на старый образ докера 1.0.2 - это работает.Я пытался с IP-адресом исходных серверов зоопарка, та же ошибка.Может кто-нибудь, пожалуйста, помогите мне с ошибкой, и есть ли что-то специально для производителя зеркал 2.2.0?Разница лишь в том, что kafka i обновлен с 1.0.0 до 2.2.0 - все остальное остается прежним.

1 Ответ

0 голосов
/ 22 мая 2019

Перемещение комментария к ответу ...

Похоже, ошибка указывает на то, что вы неправильно настроили свойство bootstrap.servers в файле consumer.properties.

Использование Zookeeper в качестве единственной строки подключения не должно использоваться ни в одной из упомянутых вами версий Kafka.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...