使用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。
你的答案