首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >Vagrant中的Kafka集群(ZK,BR,BR,BR)不能建立连接。

Vagrant中的Kafka集群(ZK,BR,BR,BR)不能建立连接。
EN

Stack Overflow用户
提问于 2017-12-28 22:00:57
回答 1查看 228关注 0票数 0

问题是,我无法通过生产者脚本向集群中的任何代理发送消息。

安装程序是运行在带有默认设置的ip ( 192.168.10.2:2181)上的单一动物园管理员服务器。

此外,还有3个代理运行在(192.168.10.101:9092,192.168.10.102:9092,192.168.10.103:9092).上。

在旋起代理之后,我可以在动物园管理员外壳中看到3个代理是连接的。

代码语言:javascript
复制
vagrant ssh zookeeper-1
kafka/bin/zookeeper-shell.sh 192.168.10.2:2181
ls /brokers/ids

输出:

连接到192.168.10.2:2181欢迎来到ZooKeeper!禁用JLine支持监视程序::WatchedEvent状态:SyncConnected类型:无路径:null ls /brokers/ids 3、2、1

现在我可以用复制创建主题:

代码语言:javascript
复制
kafka/bin/kafka-topics.sh --create --zookeeper 192.168.10.2:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic

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

代码语言:javascript
复制
kafka/bin/kafka-topics.sh --describe --zookeeper 192.168.10.2:2181 --topic my-replicated-topic

输出:

主题:我的-复制-主题部分计数:1复制因子:3内容:主题:我的-复制-主题划分:0领袖:3个副本: 3,1,2 Isr: 3,1,2

如果我现在试图通过制片人发送信息:

代码语言:javascript
复制
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警告生产者clientId=控制台-生产者连接到节点-3无法建立。可能找不到经纪人。(org.apache.kafka.clients.NetworkClient) 2017-12-28 13:53:30,536警告生产者clientId=控制台-生产者与节点-2的连接无法建立。可能找不到经纪人。(org.apache.kafka.clients.NetworkClient) 2017-12-28 13:53:30,539警告生产者clientId=控制台-生产者连接到节点-1无法建立。可能找不到经纪人。(org.apache.kafka.clients.NetworkClient)

如果我试图从代理框中发送消息,也会发生同样的情况。

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

我现在基本上搜索了几个小时,希望在座的任何人--也许现在--都能解决这个问题。我想这只是一个配置设置,我看不见。

EN

回答 1

Stack Overflow用户

发布于 2017-12-29 00:30:16

代理,即使他应该知道自己的地址,也需要在自己的设置中定义为‘“listeners=明文://”$BROKER_IP“:9092”“。

票数 -1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/48014906

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档