使用脚本时，我无法向Kafka生成数据，但我可以列出脚本中的主题

Question

各位，局域网中有一个虚拟服务器，ip是192.168.18.230，我的机器ip是192.168.0.175。今天，我尝试使用我的机器（192.168.0.175）向我的虚拟服务器（192.168.18.230）发送一些消息，使用Kafka控制台生成器

$ bin/kafka-console-producer.sh --broker-list 192.168.18.230:9092 --topic test

但有点不对劲。问题描述如下：

[2017-04-10 17:25:40,396] ERROR Error when sending message to topic test with key: null, value: 6 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for test-0 due to 1568 ms has passed since batch creation plus linger time

但当我使用kafka topics脚本列出主题时，它是有效的：

$ bin/kafka-topics.sh --list --zookeeper 192.168.18.230:2181

这个问题困扰了我很长一段时间，有人能帮我解决吗？

Answer 1

您的Kafka producer可能正在无法访问运行Kafka代理的虚拟机的计算机上运行。

此外，代理端口不仅应该是开放的，而且必须由代理负责，也就是说，您的Kafka代理的（公布的）侦听器必须具有您的虚拟机IP（可以从您的Kafka制作者运行的位置访问IP，因为一个VM可以有多个IP，并且没有规则规定所有IP都可以访问）。

例如，你的虚拟机有两个IP1.2.3.4和4.3.2.1，而你在另一台机器上的制作人指向1.2.3.4，你必须首先能够ping和telnet到这个IP。

接下来，你必须在你的Kafka经纪人的广告听众中有这个IP1.2.3.4。

advertised.listeners=PLAINTEXT://1.2.3.4:9092

您应该在Kafka Producer中将此IP设置为您的bootstrap.servers。

您还应该确保端口不仅对localhost或127.0.0.1开放，例如，当您使用netstat时，它不应该只有localhost:9092或127.0.0.1:9092，它应该使用任何本地地址0.0.0.0或您的IP1.2.3.4:9092

Answer 2

如果你有一个zookeeper实例正在运行，你当然可以询问主题列表。然而，你似乎没有Kafka经纪人。

你可能有一个动物园管理员在跑步，但Kafka没有。