Kafka - 获取具有相关 ID 的元数据时出错 - LEADER_NOT_AVAILABLE

Posted 2023-03-10

【中文标题】Kafka - 获取具有相关 ID 的元数据时出错 - LEADER_NOT_AVAILABLE

【英文标题】：Kafka - Error while fetching metadata with correlation id - LEADER_NOT_AVAILABLE

【发布时间】：2016-10-20 12:11:00

【问题描述】：

我已经在本地设置了 Kafka 集群。三个具有属性的经纪人：

broker.id=0
listeners=PLAINTEXT://:9092

broker.id=1
listeners=PLAINTEXT://:9091

broker.id=2
listeners=PLAINTEXT://:9090

一切正常，但我现在收到错误：

获取关联 ID 为 1 的元数据时出现警告错误：TRAIL_TOPIC=LEADER_NOT_AVAILABLE (org.apache.kafka.clients.NetworkClient)

我也在尝试通过基于 Java 的客户端编写消息，但出现错误：无法在 6000 毫秒内获取元数据。

【问题讨论】：

主题好像不存在

【参考方案1】：

我也遇到了同样的问题，是因为topic不存在，brokerauto.create.topics.enable的配置默认设置为false。我使用的是bin/connect-standalone，所以我没有指定我将使用的主题。

我将此配置更改为true，它解决了我的问题。

【讨论】：

LEADER_NOT_AVAILABLE 的原因有很多。最常见的是复制不工作，或者代理关闭...当领导者可用时，您会收到UNKNOWN_TOPIC_OR_PARTITION 的不同消息。此外，在使用 Source 连接器时，您真的应该提前创建主题。同样，对于 Sink 连接器，需要有一个现有主题可供读取。

@OneCricketeer 谢谢你的建议！如果我在解决问题时能看到这样的评论，那就太好了。