命令：./kafka-console-producer.sh --broker-list zookeeper:9092 --topic monitor
啟動kafka生產者報錯：
原因：zookeeper端口號寫錯了！
總結：就算zookeeper端口寫錯了也能運行，但是只有再給生產者數據的時候才會報錯。
免責聲明！
本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。
猜您在找
kafka調試中遇到could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
【Kafka問題解決】Connection to xxx could not be established. Broker may not be available.
kafka: could not be established. Broker may not be available
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……
Kafka生產者producer簡要總結
啟動kafka消費報錯：WARN [Consumer clientId…] 1 partitions have leader brokers without a matching listener,…
【原創】大叔問題定位分享（9）oozie提交spark任務報 java.lang.NoClassDefFoundError: org/apache/kafka/clients/producer/KafkaProducer
Error when sending message to topic test with key: null, value: 2 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
Kafka：ZK+Kafka+Spark Streaming集群環境搭建（二十六）Structured Streaming：WARN clients.NetworkClient: Error while fetching metadata with correlation id 1 : {my-topic=LEADER_NOT_AVAILABLE}
Spark-submit 流處理報錯：NoClassDefFoundError: org/apache/kafka/clients/consumer/Consumer