来自远程服务器的Kafka Producer

Question

我正在用ApacheKafka版本（2.1.0）开发一个流式API。我有一个Kafka群集和一个外部服务器。外部服务器将生成要在Kafka群集上使用的数据。

让我们将外部服务器表示为E，将集群表示为C。E没有安装Kafka。我在上面运行一个JAR文件来生成消息。以下是Producer属性的代码段：

properties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "bootstrapIp:9092");
properties.put(ProducerConfig.CLIENT_ID_CONFIG, "producer");

我将bootstrapIp设置为Kafka代理IP。

在集群端，我使用以下命令启动使用者控制台：

kafka-console-consumer --bootstrap-server bootstrapIp:9092 --topic T1 --from-beginning

我将bootstrappip设置为集群引导服务器IP。

当在集群上运行生产者和消费者时，它工作得很好，但是当我在外部服务器（E）中运行生产者和集群（C）中运行消费者时，数据没有被消耗。

在localhost中，当我在集群中运行producer和consumer时，一切都正常（C）当在外部运行producer时，我不能使用集群中的数据。

从集群（C）到外部服务器（E）的ping正在工作，但我看不出问题到底出在哪里。

我不知道如何使用来自外部服务器的消息。

编辑

从外部服务器（E）我telnet（bootstrapIp）：telnet bootstrapIp 9092，它可以工作，我不理解这个问题

Answer 1

Tbis为我工作：来自server.properties评论

listeners=PLAINTEXT://:9092

和

advertised.listeners=PLAINTEXT://<HOST IP>:9092

用实际IP替换。我的案例：

advertised.listeners=PLAINTEXT://192.168.75.132:9092