Kafka多節點設置Zookeeper日誌中的「不合理的長度」

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 /動物園管理員/數據」仍然沒有運氣。

上的將大大appriciated

Answer 1

Vaibhav的看着這條線（引導代理主機2：2181）任何幫助看起來像你試圖連接到ZooKeeper的實例，而不是代理實例。默認情況下，Kafka代理在9092端口上運行。 斌./kafka-console-producer.sh --broker名單主機1：9092，主機2：9092 --topic 「TOPIC_NAME」

所以生產者和消費者應該按下面的命令

生產者創建消費者： bin ./kafka-console-consumer.sh --bootstrap-server：9092 - topic「topic_name」 - from-beginning