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

Недавно я обновил зеркало 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 - все остальное осталось прежним.


apache-kafka apache-kafka-mirrormaker
person OvivO    schedule 12.05.2019    source источник
comment
Вы устанавливаете bootstrap.servers то же самое в файле consumer.properties? Ошибка не в Zookeepers   -  person OneCricketeer    schedule 12.05.2019
comment
ну, это неловко, но в consumer.properties не было переменной bootstrap.servers, только zookeeper-connect, которая, похоже, устарела. Теперь проблема решена, поскольку я обновил consumer.properties до последней версии класса ConsumerConfig. Спасибо @ cricket_007   -  person OvivO    schedule 16.05.2019

Ответы (1)


arrow_upward
0
arrow_downward

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

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

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

person OneCricketeer    schedule 21.05.2019