我在我的EC2实例上安装了Apache Kafka,并更改了安全组以打开Kafka和Zookeeper的端口9092和2181。我只有一个单一的代理人、单一的主题、单一的分区,没有任何复杂的东西。我通过尝试本地的生产者/消费者来确认Kafka是否正常工作。
在AWS安全组中显示:
自定义TCP规则 TCP 2181 0.0.0.0/0
自定义TCP规则 TCP 9092 0.0.0.0/0
现在,我想使用我的Broker EC2实例的公共IP连接我的生产者和消费者(不在Amazon EC2实例上)。然而,我无法将任何生产者或消费者连接到EC2 Broker。它们只是说Broker未找到。
请您帮忙解决这个问题,谢谢!
在AWS安全组中显示:
自定义TCP规则 TCP 2181 0.0.0.0/0
自定义TCP规则 TCP 9092 0.0.0.0/0
现在,我想使用我的Broker EC2实例的公共IP连接我的生产者和消费者(不在Amazon EC2实例上)。然而,我无法将任何生产者或消费者连接到EC2 Broker。它们只是说Broker未找到。
请您帮忙解决这个问题,谢谢!
telnet <public name> 2181
telnet <public name> 9092
如果没有被拒绝并且您可以输入文本,则表示没有网络问题。否则,您将获得更好的线索以了解是什么阻止了通信。 - erankl