Kafka多节点在Zookeeper日志中设置“不合理的长度”

Question

我已经为 kafka 设置了一个多节点设置，一切似乎都运行良好并且不显示任何错误日志，除非我尝试将消息推送到一个生产者。我收到一条消息：

Bootstrap 代理主机 2:2181 断开连接 (org.apache.kafka.clients.NetworkClient)

在动物园管理员日志上，我得到：

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

我清理了我的数据目录“/var/zookeeper/data”仍然没有运气。

任何帮助都会非常有用

Answer 1

Vaibhav 看着这一行 (Bootstrap broker host2:2181) 看起来您正在尝试连接到 zookeeper 实例而不是 broker 实例。默认情况下，Kafka 代理在 9092 端口上运行。所以生产者和消费者应该按照下面的命令创建

制作人：

bin/kafka-console-producer.sh --broker-list host1:9092,host2:9092 \
  --topic "topic_name"

消费者：

bin/kafka-console-consumer.sh --bootstrap-server <host_ip_of_producer>:9092 \
  --topic "topic_name" --from-beginning