报错
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group=app-topic-group --topic app-topic
[2018-05-28 14:15:09,048] WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead. (kafka.tools.ConsumerOffsetChecker$)
Exiting due to: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/app-topic-group/offsets/app-topic/3.
排查过程
kafka 数据清除
zk数据清除
topic更换为新的
报错依旧。
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic app-topic
命令可以接收正常数据
取消logstash的
enable_auto_commit => false
恢复正常