,假设Kafka在AWS EC2实例上作为单个节点代理运行。该实例具有内部私有IP 10.0.0.1
。我想直接从同一EC2实例和同一VPC和子网中的另一个EC2实例连接到该经纪人。安全组允许连接。我必须使用哪些设置才能运行连接?
我尝试了listeners=PLAINTEXT://0.0.0.0:9092
和advertised.listeners=PLAINTEXT://0.0.0.0:9092
。使用该设置,我可以从Local(经纪人正在运行的同一实例(连接到经纪人,但是我无法从第二个EC2实例接触经纪人。
有人有任何想法吗?
如果您要连接到一个从一个EC2实例到另一个ec2实例的KAFKA实例,则内部IP地址应起作用。
生产者和消费者也应为经纪人和Zookeeper使用内部私人IP地址。
此外,您可能需要验证OS级别的IP表不会阻止通信。