KAFKA服务器属性 - 无法连接到经纪人



,假设Kafka在AWS EC2实例上作为单个节点代理运行。该实例具有内部私有IP 10.0.0.1。我想直接从同一EC2实例和同一VPC和子网中的另一个EC2实例连接到该经纪人。安全组允许连接。我必须使用哪些设置才能运行连接?

我尝试了listeners=PLAINTEXT://0.0.0.0:9092advertised.listeners=PLAINTEXT://0.0.0.0:9092。使用该设置,我可以从Local(经纪人正在运行的同一实例(连接到经纪人,但是我无法从第二个EC2实例接触经纪人。

有人有任何想法吗?

如果您要连接到一个从一个EC2实例到另一个ec2实例的KAFKA实例,则内部IP地址应起作用。

生产者和消费者也应为经纪人和Zookeeper使用内部私人IP地址。

此外,您可能需要验证OS级别的IP表不会阻止通信。