kafka集群(zk,br,br,br)在vagrant中无法建立连接

mspsb9vt  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(414)

问题是我无法通过producer脚本将消息发送到集群中的任何代理。
该设置是一个zookeeper服务器,在ip(192.168.10.2:2181)上以默认设置运行。
此外,还有3个代理正在运行(192.168.10.101:9092192.168.10.102:9092192.168.10.103:9092)。
在旋转代理之后,我可以在zookeeper shell中看到3个代理已经连接。

vagrant ssh zookeeper-1
kafka/bin/zookeeper-shell.sh 192.168.10.2:2181
ls /brokers/ids

输出:
连接192.168.10.2:2181欢迎来到Zookeeper!jline支持已禁用watcher::watchedeventstate:syncconnected type:无path:null ls /经纪人/ID[3,2,1]
现在我可以创建复制主题:

kafka/bin/kafka-topics.sh --create --zookeeper 192.168.10.2:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic

之后,我验证是否创建了主题:

kafka/bin/kafka-topics.sh --describe --zookeeper 192.168.10.2:2181 --topic my-replicated-topic

输出:
topic:my-replicated-topic partitioncount:1个副本ionfactor:3 configs:topic:my replicated topic partition:0 leader:3 replicates:3,1,2 isr:3,1,2
如果我现在尝试通过制作人发送消息:

kafka/bin/kafka-console-producer.sh --broker-list 192.168.10.101:9092,192.168.10.102:9092,192.168.10.103:9092 --topic my-replicated-topic

[2017-12-28 13:53:30530]警告[producer clientid=console producer]无法建立到节点-3的连接。代理可能不可用(org.apache.kafka.clients.networkclient)[2017-12-28 13:53:30536]警告[producer clientid=console producer]无法建立到节点2的连接。代理可能不可用(org.apache.kafka.clients.networkclient)[2017-12-28 13:53:30539]警告[producer clientid=console producer]无法建立到节点-1的连接。代理可能不可用(org.apache.kafka.clients.networkclient)
如果我尝试从其中一个代理盒发送消息,也会发生同样的情况。
我在这里上传了vagrantfile+脚本,这样你就可以重现我的问题:https://github.com/0xbadbac0n/kafka-vagrant-games
我现在基本上在google上搜索了几个小时,希望这里的任何人都知道如何解决这个问题。我想这只是一个配置设置,我看不到。

hzbexzde

hzbexzde1#

代理,即使他应该知道自己的地址,也需要在自己的设置中用“'listeners=plaintext://”$broker_ip“:9092”来定义。

相关问题