kafka搭建過程的問題kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while
阿新 • • 發佈:2020-10-21
在kafka啟動時,kafka版本安裝包kafka_2.13-2.6.0.tgz,始終報錯:
kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
在網上看了很多解決方法都不行,在kafka的server.properties檔案中,zookeeper.connect配置項使用ip:port
解決方法:
將zookeeper.connect改成域名:port,然後能正常啟動。使用域名需要修改/etc/hosts檔案
1、建立topic:m-test
/kafka/bin/kafktopics.sh --create --zookeeper zk154:2181,zk155:3181,zk156:3181 --replication-factor 1 --partitions 1 --topic m-test
2、列出已建立的topic列表
/kafka/bin/kafka-topics.sh --list --zookeeper zk154:2181
3、模擬客戶端去傳送訊息
/kafka/bin/kafka-console-producer.sh --broker-list 192.168.7.148:9092 --topic m-test
4、模擬客戶端去接受訊息
/kafka/bin/kafka-console-consumer.sh --bootstrap-server 192.168.7.148:9092 --from-beginning --topic m-test