Zookeeper 日志中的 Kafka 多节点设置 "Unreasonable length"

Question

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

Bootstrap broker host2:2181 disconnected (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

Zookeeper 日志中的 Kafka 多节点设置 "Unreasonable length"

Kafka Multi Node setup "Unreasonable length" in Zookeeper logs

distributed

apache-kafka

apache-zookeeper