1. 程式人生 > 實用技巧 >kafka搭建過程的問題kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while

kafka搭建過程的問題kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while

在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