小编rai*_*rai的帖子

我在ec2上的一台机器上设置了一个kafka zookeeper和3个代理,端口为9092..9094,我正在尝试使用另一台机器上的主题内容.端口2181(zk),9092,9093和9094(服务器)对消费者机器开放.我甚至可以做一个bin/kafka-topics.sh --describe --zookeeper 172.X.X.X:2181 --topic remotetopic给我的东西

主题:remotetopic PartitionCount:1 ReplicationFactor:3配置:主题:remotetopic分区:0领导者:2个副本:2,0,1 Isr:2,0,1 Blockquote

但是当bin/kafka-console-consumer.sh --zookeeper 172.X.X.X:2181 --from-beginning --topic remotetopic我得到的时候

警告从代理[id:0,host:localhost,port:9092] 获取主题[Set(remotetopic)]的相关ID为0的主题元数据失败(kafka.client.ClientUtils $)java.nio.channels.ClosedChannelException

为什么消费者试图从localhost读取？是否有任何选项或命令行或默认文件从中读取; 我可以改变它吗？

任何帮助,将不胜感激!

我正在开发一个应用程序,在启用下载之前检查连接是否可靠(基本上连接应该是基础设施wifi而不是数据包)但是如果用户要么

1. 使用ad hoc网络,或
2. 移动设备的互联网连接为WAP

然后在桌面上连接并开始下载,它仍然是不受欢迎的.有没有办法检测某些wifi连接是否实际上不是来自ad hoc或使用手机的WAP？