我已经建立了Kafka集群与3个节点，一切都很好。
三家有房产的经纪人：
# 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)
1条答案
按热度按时间tez616oj1#
请按照以下步骤操作。
在server.properties（对于3个代理）文件中添加以下行：
哪里
host.name是kafka代理的ip地址或主机名。重新启动Kafka经纪人和测试。