问题是,我无法通过生产者脚本向集群中的任何代理发送消息。
安装程序是运行在带有默认设置的ip ( 192.168.10.2:2181)上的单一动物园管理员服务器。
此外,还有3个代理运行在(192.168.10.101:9092,192.168.10.102:9092,192.168.10.103:9092).上。
在旋起代理之后,我可以在动物园管理员外壳中看到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支持监视程序::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输出:
主题:我的-复制-主题部分计数:1复制因子:3内容:主题:我的-复制-主题划分: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-topic2017-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
我现在基本上搜索了几个小时,希望在座的任何人--也许现在--都能解决这个问题。我想这只是一个配置设置,我看不见。
发布于 2017-12-29 00:30:16
代理,即使他应该知道自己的地址,也需要在自己的设置中定义为‘“listeners=明文://”$BROKER_IP“:9092”“。
https://stackoverflow.com/questions/48014906
复制相似问题