【问题标题】:Kafka - Error while fetching metadata with correlation id - LEADER_NOT_AVAILABLEKafka - 获取具有相关 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 毫秒内获取元数据。

【问题讨论】:

  • 主题好像不存在

标签: apache-kafka


【解决方案1】:

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

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

【讨论】:

  • LEADER_NOT_AVAILABLE 的原因有很多。最常见的是复制不工作,或者代理关闭...当领导者可用时,您会收到UNKNOWN_TOPIC_OR_PARTITION 的不同消息。此外,在使用 Source 连接器时,您真的应该提前创建主题。同样,对于 Sink 连接器,需要有一个现有主题可供读取。
  • @OneCricketeer 谢谢你的建议!如果我在解决问题时能看到这样的评论,那就太好了。
猜你喜欢
  • 2019-10-06
  • 2020-12-27
  • 1970-01-01
  • 2020-01-05
  • 2020-05-15
  • 2020-07-21
  • 2018-09-26
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多