原文:Spark Streaming + Kafka 常見錯誤解析 - Connection to node [x] could not be established. Broker may not be available.

最近調試Spark Streaming Kafka,遇到一個連接錯誤,任務日志如下。 報錯之前,ConsumerConfig 被打印出來,其中bootstrap.servers顯示我們指定的brokers列表。 根據kafkatool通過ZK可以成功連接的現象,查看 etc hosts,發現brokers的地址是 . . .x 采用Java測試代碼驗證,發現 . . .x確實可以工作。結合代碼分析 ...

2019-06-23 16:23 0 4360 推薦指數:

查看詳情

kafka: could not be established. Broker may not be available

本人小白一個,網上查資料,有很多解決方案,有關閉防火牆的,有修改配置文件的,有添加host的,試了之后發現還是解決不了,最后發現是命令用錯了 過程如下: cd /opt/kafka/bin #進入kafka安裝目錄下的bin ./kafka-topics.sh --describe ...

Thu Dec 16 17:35:00 CST 2021 0 1652
KAFKAcould not be established. Broker may not be available

場景:安裝完kafka集群后,程序創建topic時報錯could not be established. Broker may not be available 問題: 1.kafka開放了9092,9093,9094這三個端口,使用語句 firewall-cmd --zone=public ...

Thu Apr 14 18:32:00 CST 2022 0 8693
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM