我已经在ec2示例上安装了apachekafka，将安全组更改为为为kafka和zookeeper打开端口9092和2181。我只有一个代理，一个主题，一个分区，没有什么复杂的。我通过尝试当地的生产者/消费者来证实Kafka的工作。
在aws安全组上显示：
自定义tcp规则tcp 2181 0.0.0.0/0
自定义tcp规则tcp 9092 0.0.0.0/0
现在我想使用代理ec2示例的公共ip连接生产者和消费者（而不是amazonec2示例）。但是，我无法将我的任何生产者或消费者连接到ec2代理。他们只是说找不到经纪人。
你能帮帮我吗？
谢谢
1条答案
按热度按时间lskq00tm1#
这可能是因为Kafka默认在zookeeper中宣传经纪人的名字。在aws上，它通常使用无法从外部解析的内部ec2dns名称。看一看这个
advertised.listeners代理配置的属性