報錯：Bootstrap broker basecoalmine:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)

本文轉載自查看原文 2020-05-19 22:21 10823 kafka

報錯背景：

新安裝的單機版kafka啟動消費者的時候報錯！

報錯現象：

[2020-05-19 22:08:04,053] WARN [Consumer clientId=consumer-console-consumer-36457-1, groupId=console-consumer-36457] Bootstrap broker basecoalmine:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
[2020-05-19 22:08:04,990] WARN [Consumer clientId=consumer-console-consumer-36457-1, groupId=console-consumer-36457] Bootstrap broker basecoalmine:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
[2020-05-19 22:08:06,086] WARN [Consumer clientId=consumer-console-consumer-36457-1, groupId=console-consumer-36457] Bootstrap broker basecoalmine:2181 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)

報錯原因：

端口號的問題，以前啟動消費者的時候監聽的端口是 2181，但是新版本的kafka對zookeeper的依賴沒有那么強烈了，所以改成了自己的 9092。

kafka-console-consumer.sh --bootstrap-server basecoalmine:2181 --topic test --from-beginning

報錯解決：

修改端口號

kafka-console-consumer.sh --bootstrap-server basecoalmine:9092 --topic test --from-beginning

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 Kafka—Bootstrap broker hadoop102:2181 (id: -1 rack: null) disconnected 報錯：Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) 啟動kafka生產者報錯： WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) kafka調試中遇到could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient) 11:57:24 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] WARN o.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-2, groupId=jiatian_api] 3 partitions have leader…… Spark-submit 流處理報錯：NoClassDefFoundError: org/apache/kafka/clients/consumer/Consumer kafka提交異常org.apache.kafka.clients.consumer.CommitFailedException Error when sending message to topic test with key: null, value: 2 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) object not serializable (class: org.apache.kafka.clients.consumer.ConsumerRecord) Kafka 排查 Discovered coordinator XXXXX:9092 (id: 2147483647 rack: null) for group itstyle.