使用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
求助,有人遇到过吗?
 
        
这个正好我遇到了,是由于zookeeper版本低于3.4.8。
你的答案