【问题标题】:Kafka ConsumerGroup does not exist卡夫卡消费者组不存在
【发布时间】:2018-06-02 07:27:56
【问题描述】:

第一次设置 Kafka,Kafka 0.11。使用几乎默认配置。 Produced 对主题 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] WARN 警告:ConsumerOffsetChecker 已弃用,并将在 0.9.0 之后的版本中删除。请改用 ConsumerGroupCommand。 (kafka.tools.ConsumerOffsetChecker$) 退出原因:org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/GROUP.1/offsets/ABC/2。

【问题讨论】:

  • 您能否提供更多详细信息,例如您的生产者和消费者代码?

标签: apache-kafka kafka-consumer-api


【解决方案1】:

正如您所说,您昨天看到了组详细信息,可能值得注意的是,默认情况下偏移量仅存储 24 小时。因此,如果您的组在 24 小时内没有提交偏移量,则 Kafka 没有关于它的更多信息。

如果确实是这个问题,您可以通过将offsets.retention.minutes 设置为更大的值来增加时间。

【讨论】:

  • 啊,应该就是这个了。
  • 就像整个 ConsumerGroup 的详细信息都已过期,而不仅仅是 Offset。所以属性名称 - offsets.retention.* 有点误导,不是吗?
  • ^ 在这里相同。我的消费者群体也被完全“抹杀”了它的任何历史
猜你喜欢
  • 2021-08-22
  • 1970-01-01
  • 2022-07-13
  • 1970-01-01
  • 2019-07-03
  • 2018-05-05
  • 1970-01-01
  • 2016-12-17
  • 1970-01-01
相关资源
最近更新 更多