首页 文章

Vagrant中的Kafka Cluster(ZK,BR,BR,BR)无法 Build 连接

提问于
浏览
0

问题是我无法通过 生产环境 者脚本向集群内的任何代理发送消息 .

该设置是一个使用默认设置在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

Output:

连接到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

Output:

主题: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]无法 Build 与节点-3的连接 . 经纪人可能无法使用 . (org.apache.kafka.clients.NetworkClient)[2017-12-28 13:53:30,536] WARN [Producer clientId = console-producer]无法 Build 与节点-2的连接 . 经纪人可能无法使用 . (org.apache.kafka.clients.NetworkClient)[2017-12-28 13:53:30,539] WARN [Producer clientId = console-producer]无法 Build 与节点-1的连接 . 经纪人可能无法使用 . (org.apache.kafka.clients.NetworkClient)

如果我尝试从其中一个代理框发送消息,也会发生同样的情况 .

我在这里上传了Vagrantfile脚本,以便您可以重现我的问题:https://github.com/0xBADBAC0N/kafka-vagrant-games

我现在基本上用谷歌搜索了几个小时,希望现在这里的任何人都可以解决这个问题 . 我想这只是一个我看不到的配置设置 .

1 回答

  • -1

    经纪人,即使他应该知道自己的地址,也需要在他自己的设置中用'“listeners = PLAINTEXT://”$ BROKER_IP“:9092”'来定义 .

相关问题