新搭建一套kafka集群,配置用的老的一樣的配置,應該很快能夠搞定,結果搞了一天,問題如下,
搭建完成後使用如下命令做生產者測試產生新資料:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
123稍等下出現如下報錯:
[2020-09-10 19:19:12,798] error error when sending message to topic test with key: null, value: 0 bytes with error: (org.apache.kafka.clients.producer.internals.errorloggingcallback)
org.apache.kafka.common.errors.timeoutexception: failed to update metadata after 60000 ms.
同時消費者也沒收到資料,如下命令:
#消費訊息
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
搜尋了一陣,給的方案這樣的:
listeners=plaintext://hostip:9092
advertised.listeners=plaintext://hostip:9092
port=9092
然鵝,重啟後問題依舊未解決,再搜尋,說是生產訊息需要用broker所在的機器ip ,即生產訊息的時候需要將下邊的命令需要修改
#生產訊息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
改為 hostip為執行命令機器ip:
bin/kafka-console-producer.sh --broker-list hostip:9092 --topic test
重試了下果真可以,問題解決,真是坑坑。。
kafka使用命令
上面的步驟都執行完了,環境算是好了,下面我們要測試下是否能成功執行kafka 1.啟動zookeeper server bin zookeeper server start.sh config zookeeper.properties 用 是為了能退出命令列 2.啟動kafka server bin...
kafka使用總結
列出所有topics bin kafka topics.sh list zookeeper 10.19.167.11 2181,10.19.167.12 2181,10.19.167.14 2181 bin kafka topics.sh list zookeeper 10.19.167.21 21...
kafka使用總結
系統新增資料需要通過kafka平台進行推送,第三方消費訊息 1.伺服器端需要安裝jdk,kafka 2.6.0 使用kafka自帶zookeeper jdk配置對應的環境變數,kafka使用預設配置 2.啟動順序為 zookeeper啟動之後 啟動kafka 關閉順序為 kafka關閉之後 關閉zo...