最近在学习kafka 要搭建集群测试,在搭建的过程中遇到一些问题 记录下

linux版本:centos8

zookeeper版本:3.6.2

kafka版本:2.7.0

参考文章:https://blog.csdn.net/matrix_google/article/details/86684832

共3台机器,ip都做了映射

/etc/host配置:

127.0.0.1 localhost localhost.localdomain localhost4 localhost4.localdomain4 x64-1

::1 localhost localhost.localdomain localhost6 localhost6.localdomain6

192.168.70.81 x64-1

192.168.70.82 x64-2

192.168.70.83 x64-3

 

kafka server.properties配置:

listeners=PLAINTEXT://x64-1:9092

 

以上配置3台机器kafka启动后

执行消费者命令: kafka-console-consumer.sh --bootstrap-server x64-1:9092,x64-2:9092,x64-3:9092 --topic test1

就报这个错 could not be established. Broker may not be available host

经查发现listeners实际绑定是127.0.0.1,而其他节点访问x64-1这个节点的都是192.168.70.81:9092 

所以这里ip就对不上了 需要把上面/etc/host中红色的127.0.0.1改成本机实际的ip 3台机器就能访问通了

 

 

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐