在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

Logo

大数据从业者之家,一起探索大数据的无限可能!

更多推荐