使用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
求助,有人遇到过吗?
征集:如果你也是一个热爱分享文章的人,愿意参与贡献文章来补充完善本网的内容,欢迎入群:14085484
发表于: 1年前 最后更新时间: 1年前 游览量:1151
下一条: fluentd+kafka fluentd发送消息给kafka, kafka consumer没有内容?