use*_*706 2 apache-kafka kafka-consumer-api
首次设置Kafka,Kafka 0.11。使用几乎所有默认配置。产生了一些关于主题ABC的消息。2使用者被编码为使用来自同一主题的消息。每个使用者都属于不同的组ID GROUP.1和GROUP.2
想要查看所有消息的主题以及偏移量详细信息。
kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group GROUP.1
Run Code Online (Sandbox Code Playgroud)
引发以下错误,
错误:使用者组“ 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
Run Code Online (Sandbox Code Playgroud)
[2017-12-19 19:25:01,654]警告:不推荐使用ConsumerOffsetChecker,并将在0.9.0之后的版本中删除。请改用ConsumerGroupCommand。(kafka.tools.ConsumerOffsetChecker $)由于以下原因而退出:org.apache.zookeeper.KeeperException $ NoNodeException:KeeperErrorCode = Nocons for /consumers/GROUP.1/offsets/ABC/2。
如您所说,您昨天看到了组的详细信息,可能值得注意的是,默认情况下,偏移量仅存储24小时。因此,如果您的分组没有在24小时内提交偏移,则Kafka没有有关此的更多信息。
如果确实是问题所在,则可以通过将其设置offsets.retention.minutes为更大的值来增加时间。
| 归档时间: |
|
| 查看次数: |
2243 次 |
| 最近记录: |