Настройка Kafka Multi Node «Необоснованная длина» в журналах Zookeeper

Question

У меня есть настройка нескольких узлов для kafka, все, кажется, работает хорошо и не отображает журналы ошибок, если я не пытаюсь нажимать сообщение одному производителю. Я получаю сообщение:

" Bootstrap broker host2:2181 disconnected(org.apache.kafka.clients.NetworkClient)"

и на бревнах Zookeeper я получаю:

"WARN Exception causing close of session 0x0 due to java.io.IOException: 
Unreasonable length = 1701969920 (org.apache.zookeeper.server.NIOServerCnxn)" 

я очищенную мой каталог данных, который не является "/ Var/Zookeeper/данные" по-прежнему не повезло ,

Любая помощь на в будет много appriciated

Answer 1

Vaibhav глядя на этой линии (Bootstrap брокер host2: 2181) Похоже, что вы пытаетесь подключиться к Zookeeper экземпляр, а не экземпляр брокера. По умолчанию брокер Kafka работает на порту 9092. Так производитель и потребитель должен быть создан в соответствии с ниже команды

Производитель: бин ./kafka-console-producer.sh --broker-лист host1: 9092, host2: 9092 --topic "TOPIC_NAME"

Потребитель: bin ./kafka-console-consumer.sh --bootstrap-server: 9092 --topic "topic_name" - от начала