Vagrant中的Kafka Cluster(ZK,BR,BR,BR)无法建立连接
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Vagrant中的Kafka Cluster(ZK,BR,BR,BR)无法建立连接相关的知识,希望对你有一定的参考价值。
问题是我无法通过生产者脚本向集群内的任何代理发送消息。
该设置是一个使用默认设置在ip(192.168.10.2:2181)上运行的单个zookeeper服务器。
此外,有3个经纪人在运行(192.168.10.101:9092,192.168.10.102:9092,192.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 :: WatchedEvent状态:SyncConnected类型:无路径:null ls / brokers / ids [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
输出:
主题:my-replicated-topic PartitionCount:1 ReplicationFactor:3配置:主题:my-replicated-topic分区:0领导者:3个副本: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:30,530] WARN [Producer clientId = console-producer]无法建立与节点-3的连接。经纪人可能无法使用。 (org.apache.kafka.clients.NetworkClient)[2017-12-28 13:53:30,536] WARN [Producer clientId = console-producer]无法建立与节点-2的连接。经纪人可能无法使用。 (org.apache.kafka.clients.NetworkClient)[2017-12-28 13:53:30,539] WARN [Producer clientId = console-producer]无法建立与节点-1的连接。经纪人可能无法使用。 (org.apache.kafka.clients.NetworkClient)
如果我尝试从其中一个代理框发送消息,也会发生同样的情况。
我在这里上传了Vagrantfile +脚本,以便您可以重现我的问题:https://github.com/0xBADBAC0N/kafka-vagrant-games
我现在基本上用谷歌搜索了几个小时,希望现在这里的任何人都可以解决这个问题。我想这只是一个我看不到的配置设置。
经纪人,即使他应该知道自己的地址,也需要在他自己的设置中用'“listeners = PLAINTEXT://”$ BROKER_IP“:9092”'来定义。
以上是关于Vagrant中的Kafka Cluster(ZK,BR,BR,BR)无法建立连接的主要内容,如果未能解决你的问题,请参考以下文章