本地主机无法使用 Kafka 代理

Question

我已经安装kafka_2.11-1.1.0并将广告监听器设置为advertised.listeners=PLAINTEXT://<my-ip>:9092(in $KAFKA_HOME/config/server.properties)。

我可以使用 java 代码连接并写入我的 kafka，并通过kafka-tool另一台服务器查看我的集群，但我无法从本地机器（我在其上安装了 kafka 集群的机器）向我的主题写入消息。

我也尝试将 listeners 值设置为，listeners = PLAINTEXT://:9092但没有任何变化。我应该如何处理我的 kafka 以使其从本地主机的外部和内部都可以访问和写入？

Answer 1

在 server.properties 中使用以下两个属性

listeners=PLAINTEXT://0.0.0.0:9092 
advertised.listeners=PLAINTEXT://<your ip>:9092

Answer 2

我终于通过将代码org.apache.kafka库从 version更改1.1.0为 version解决了这个问题2.1.0。

我提到所有这些库都是通过导入（下载）和使用的mvnrepository.com。

此外，我们的 kafka 生产者和消费者代码模式是使用这篇文章编写的： https://dzone.com/articles/kafka-producer-and-consumer-example。