Kafka客户端无法接收消息

Question

我在远程机器上设置了Kafka和动物园管理员。在那台机器上，我可以看到下面使用官方网站上的测试方法工作。

> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic listings-incoming
This is a message
This is another message

> bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --listings-incoming --from-beginning
This is a message
This is another message

但是当我使用本地消费者脚本时，它就不起作用了：

bin/kafka-console-consumer.sh —bootstrap-server X.X.X.X:9092 —listings-incoming —from-beginning —consumer-property group.id=group2

advertised.listeners=PLAINTEXT://the.machine.ip.address:9092

我试着把它改成：

advertised.listeners=PLAINTEXT://my.client.ip.address:9092

然后运行客户端使用者脚本，它会给出错误：

[2017-08-11 15:49:01,591]获取相关id为3的元数据时警告错误：{listings-incoming=leader_not_available}(org.apache.kafka.clients.networkclient)[2017-08-11 15:49:22,106]警告引导代理10.161.128.238:9092断开连接(org.apache.kafka.clients.networkclient)[2017-08-11 15:49:22,232]获取相关id为7的元数据时警告错误：{listings-incoming=leader_not_available}-11 15:49:22,340]获取相关id为8的元数据时警告错误：{listings-incoming=leader_not_available}(org.apache.kafka.clients.networkclient)[2017-08-11 15:49:40,453]警告引导代理10.161.128.238:9092断开连接(org.apache.kafka.clients.networkclient)[2017-08-11 15:49:40,531]获取相关id为12的元数据时警告错误：{listings-incoming=leader_not_availability}

Answer 1

您可能没有在brokers server.properties文件中正确配置adversed.listeners。

摘自https://kafka.apache.org/documentation/

adversed.Listeners要发布到ZooKeeper供客户端使用的监听器（如果与上面的监听器不同）。在IaaS环境中，这可能需要与代理绑定到的接口不同。如果未设置此值，则将使用侦听器的值。

因此，如果没有设置adveredsed.listeners，并且listeners只是在监听localhost:9092或127.0.0.1:9092或0.0.0.0:9092，那么当客户机向引导服务器发出元数据请求时，就会被告知连接到localhost:9092。当客户机实际上与代理在同一台机器上运行时，这可以工作，但当远程连接时，它将失败。

您应该将adveredsed.listeners设置为运行代理的主机的完全限定域名或公共IP地址。

例如

adveredsed.listeners=plaintext://192.168.1.101:9092