第一次成立 Kafka , Kafka 0.11 . 使用几乎默认的配置 . 制作了一些消息给主题ABC . 2消费者被编码为使用来自同一主题的消息 . 每个消费者属于不同的组ID GROUP.1和GROUP.2
想要查看所有消息的主题以及偏移详细信息 .
kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group GROUP.1
抛出以下错误,
错误:消费者组'GROUP.1'不存在 .
GROUP.2也有相同的错误 . 我昨天给了其中一个小组但没有错误输出,但今天没有 . 我错过了什么?需要在某处配置以保留使用者组的详细信息,或者只有当具有给定组ID的使用者当前正在运行时,该命令才会起作用,或者?
我试过 kafka-consumer-groups --zookeeper localhost:2181 --describe --group GROUP.1
但得到了同样的错误 .
还尝试了Kafka-consumer-offset-checker命令 .
kafka-consumer-offset-checker --zookeeper localhost:2181 --topic ABC --group GROUP.1
[2017-12-19 19:25:01,654]警告警告:ConsumerOffsetChecker已弃用,将在0.9.0之后的版本中删除 . 请改用ConsumerGroupCommand . (kafka.tools.ConsumerOffsetChecker $)由于以下原因而退出:org.apache.zookeeper.KeeperException $ NoNodeException:KeeperErrorCode = Noconsode为/consumers/GROUP.1/offsets/ABC/2 .
1 回答
正如你所说,你昨天看到了小组的详细信息,可能值得注意的是,默认情况下,偏移仅存储了24小时 . 因此,如果您的小组未在24小时内提交抵消,Kafka就没有更多相关信息 .
如果这确实是问题,您可以通过将
offsets.retention.minutes
设置为更大的值来增加时间 .