获取具有相关性的元数据时发生 Kafka Confluent 错误答案

【问题标题】：Kafka Confluent Error while fetching metadata with correlation获取具有相关性的元数据时发生 Kafka Confluent 错误
【发布时间】：2018-09-26 03:10:41
【问题描述】：

我已经设置了 3 个节点的 Kafka 集群，一切都很好。

三个经纪人的属性：

#listeners=PLAINTEXT://:9092
zookeeper.connect=109.169.xx.xx:2181,88.150.xxx.xxx:2181,5.152.xxx.xxx:2181

broker.id 对每一个都是唯一的。我停止并启动了其中一个经纪人：

/opt/kafka/confluent-4.0.0/bin/kafka-server-stop

和

nohup /opt/kafka/confluent-4.0.0/bin/kafka-server-start /opt/kafka/confluent-4.0.0/etc/kafka/server.properties &

现在当我想狡猾的时候：

/opt/kafka/confluent-4.0.0/bin/kafka-console-consumer --bootstrap-server  109.169.xxx.xx:9092 --topic test_set_retention_nwq --from-beginning

出现此错误消息：

[2018-04-16 15:51:40,974] WARN [Consumer clientId=consumer-1, groupId=console-consumer-13964] Error while fetching metadata with correlation id 14 : 
{test_set_retention_nwq=UNKNOWN_TOPIC_OR_PARTITION} 
(org.apache.kafka.clients.NetworkClient)
[2018-04-16 15:51:41,075] WARN [Consumer clientId=consumer-1, groupId=console-consumer-13964] Error while fetching metadata with correlation id 15 : 
{test_set_retention_nwq=UNKNOWN_TOPIC_OR_PARTITION} 
(org.apache.kafka.clients.NetworkClient)
[2018-04-16 15:51:41,176] WARN [Consumer clientId=consumer-1, groupId=console-consumer-13964] Error while fetching metadata with correlation id 16 : 
{test_set_retention_nwq=UNKNOWN_TOPIC_OR_PARTITION} 
(org.apache.kafka.clients.NetworkClient)
[2018-04-16 15:51:41,278] WARN [Consumer clientId=consumer-1, groupId=console-consumer-13964] Error while fetching metadata with correlation id 17 : 
{test_set_retention_nwq=UNKNOWN_TOPIC_OR_PARTITION} 
(org.apache.kafka.clients.NetworkClient)

【问题讨论】：

你的话题真的存在吗？跑的时候找到了吗：/opt/kafka/confluent-4.0.0/bin/kafka-topics --zookeeper 109.169.xx.xx:2181 --list？
是的。我运行这个命令，主题就在那里@QuentinGeff
好的，您能检查一下您的 Zookeeper 实例是否运行正常吗？ ; 109.169.xx.xx:2181,88.150.xxx.xxx:2181,5.152.xxx.xxx:2181
如何确保 zookeeper 正常工作？

标签： apache-kafka

【解决方案1】：

请按照以下步骤操作。

在 server.properties（用于 3 个代理）文件中添加以下行：
```
listeners=PLAINTEXT://host.name:port
advertised.listeners=PLAINTEXT://host.name:port 
```
其中host.name 是 Kafka 代理的 IP 地址或主机名。
重新启动 Kafka 代理并进行测试。

【讨论】：