一直报Topic metadata fetch included errors: {streams-wordcount-processor-Counts-changelog=LEADER_NOT_AVAILABLE}

小蕊 发表于: 2016-11-30   最后更新时间: 2016-11-30 18:21:13   3,425 游览

使用WordCountProcessorDemo,重启kafka服务器后,用的debug级别的日志,一直刷这个,卡在这里了

2016-11-30 16:38:00] [DEBUG] o.a.k.clients.consumer.internals.Fetcher 272 -- [] Topic metadata fetch included errors: {streams-wordcount-processor-Counts-changelog=LEADER_NOT_AVAILABLE}
[2016-11-30 16:38:00] [DEBUG] o.a.k.clients.consumer.internals.Fetcher 272 -- [] Topic metadata fetch included errors: {streams-wordcount-processor-Counts-changelog=LEADER_NOT_AVAILABLE}
[2016-11-30 16:38:01] [DEBUG] o.a.k.clients.consumer.internals.Fetcher 272 -- [] Topic metadata fetch included errors: {streams-wordcount-processor-Counts-changelog=LEADER_NOT_AVAILABLE}
[2016-11-30 16:38:01] [DEBUG] o.a.k.clients.consumer.internals.Fetcher 272 -- [] Topic metadata fetch included errors: {streams-wordcount-processor-Counts-changelog=LEADER_NOT_AVAILABLE}
[2016-11-30 16:38:01] [DEBUG] o.a.k.clients.consumer.internals.Fetcher 272 -- [] Topic metadata fetch included errors: {streams-wordcount-processor-Counts-changelog=LEADER_NOT_AVAILABLE}
[2016-11-30 16:38:01] [DEBUG] o.a.k.clients.consumer.internals.Fetcher 272 -- [] Topic metadata fetch included errors: {streams-wordcount-processor-Counts-changelog=LEADER_NOT_AVAILABLE}

我查看了下集群状态,是正常的

[root@linux21-56 kafka_2.11-0.10.1.0]# bin/kafka-topics.sh --describe --zookeeper 10.xx.xx:2181 --topic streams-wordcount-processor-Counts-changelog
Topic:streams-wordcount-processor-Counts-changelog    PartitionCount:1    ReplicationFactor:1    Configs:cleanup.policy=compact
    Topic: streams-wordcount-processor-Counts-changelog    Partition: 0    Leader: 1    Replicas: 1    Isr: 1

求助,有人遇到过吗?

发表于 2016-11-30

这个正好我遇到了,是由于zookeeper版本低于3.4.8。

你的答案

查看kafka相关的其他问题或提一个您自己的问题