我已经为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/data”，仍然没有运气。
在这方面的任何帮助都将是非常感激的
1条答案
按热度按时间drnojrws1#
vaibhav看到这一行（bootstrap broker host2:2181）时，看起来您正试图连接到zookeeper示例，而不是broker示例。默认情况下，kafka代理在9092端口上运行。所以应该按照下面的命令创建生产者和消费者
producer:bin./kafka-console-producer.sh--代理列表host1:9092，host2:9092--主题“主题名称”
consumer:bin./kafka-console-consumer.sh--引导服务器：9092--主题“主题名称”--从头开始