线上集群使用flume持久化数据到hive中,使用kafka-consumer-groups查看消费组使用情况,显示unknown。请问这是什么原因造成的?
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zkconnect localhost:2181 --group test试试这个。
这个是将消费情况存储在zk中才使用的命令吧,我们现在是存储在kafka中,而且kafka集群已启用kerberos认证。
消息有被消费吗?一般这种情况是没有消费的时候才会这样。
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zkconnect localhost:2181 --group test
试试这个。
这个是将消费情况存储在zk中才使用的命令吧,我们现在是存储在kafka中,而且kafka集群已启用kerberos认证。
消息有被消费吗?一般这种情况是没有消费的时候才会这样。
你的答案