Consumer is not subscribed to any topics
Consumer is not subscribed to any topics
九州暮云
发布于 2019-08-21 11:13:02
发布于 2019-08-21 11:13:02
文章被收录于专栏：九州牧云
产生该问题的原因主要是zookeeper中存在旧版本的kafka-connect topic信息，导致新版本的kafka-connect启动异常：
ERROR Unexpected exception in Thread[KafkaBasedLog Work Thread - connect-configs,5,main] (org.apache.kafka.connect.util.KafkaBasedLog:334)
java.lang.IllegalStateException: Consumer is not subscribed to any topics or assigned any partitions
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1109)
at org.apache.kafka.connect.util.KafkaBasedLog.poll(KafkaBasedLog.java:256)
at org.apache.kafka.connect.util.KafkaBasedLog.access$500(KafkaBasedLog.java:69)
at org.apache.kafka.connect.util.KafkaBasedLog$WorkThread.run(KafkaBasedLog.java:327)解决办法：
（1） 使用kafka命令列出所有与connect相关的topic：
bin/kafka-topics.sh --list --zookeeper 10.255.8.102:2181输出：
__consumer_offsets
ambari_kafka_service_check
connect-configs
connect-offsets
connect-status（2）使用kafka命令删除所有与connect相关的topic：
bin/kafka-topics.sh --delete --zookeeper 10.255.8.102:2181 --topic connect-configs
bin/kafka-topics.sh --delete --zookeeper 10.255.8.102:2181 --topic connect-offsets
bin/kafka-topics.sh --delete --zookeeper 10.255.8.102:2181 --topic connect-status最后验证是否删除：
bin/kafka-topics.sh --list --zookeeper 10.255.8.102:2181输出：
__consumer_offsets
ambari_kafka_service_check
connect-configs - marked for deletion
connect-offsets - marked for deletion
connect-status - marked for deletion输出信息中显示三个connect topic已被标记删除了，要想彻底删除，需要在kafka的server.properties配置文件里设置delete.topic.enable=true
本文参与 腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
腾讯云开发者
