第一次设置Kafka,Kafka0.11。几乎使用默认配置。给主题发了一些信息。2个使用者被编码为使用来自同一主题的消息。每个消费者都属于不同的组id group.1和group.2
希望查看所有邮件的主题以及偏移量详细信息。
kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group GROUP.1
抛出以下错误,
错误:使用者组“group.1”不存在。
组2也有同样的错误。昨天我得到了一个小组的一些输出,没有出错,但今天没有。我错过了什么?需要在某处配置以持久化使用者组详细信息,或者该命令仅在具有给定组id的使用者当前正在运行时才起作用,或者?
我试过了 kafka-consumer-groups --zookeeper localhost:2181 --describe --group GROUP.1
但也有同样的错误。
还尝试了kafka消费偏移检查器命令。
kafka-consumer-offset-checker --zookeeper localhost:2181 --topic ABC --group GROUP.1
[2017-12-19 19:25:01654]警告:consumeroffsetchecker已弃用,将在0.9.0之后的版本中删除。改用consumergroupcommand(kafka.tools.consumerofsfsetchecker$)退出原因:org.apache.zookeeper.keeperexception$nonodeexception:keeperrorcode=nonode for/consumers/group.1/offsets//2。
1条答案
按热度按时间i5desfxk1#
正如您昨天所说,您看到了组的详细信息,可能值得注意的是,默认情况下偏移量只存储24小时。所以如果你的团队在24小时内没有提交补偿,Kafka就没有更多的信息了。
如果这确实是问题所在,可以通过设置
offsets.retention.minutes
更大的价值。