【发布时间】:2022-04-26 13:28:27
【问题描述】:
我最大的问题是,我们在 kafka 中是否有一个称为 consumer group 的概念来不活跃/活跃。
我不确定如何在我的本地 kafka 服务器中实现这一点。
任何人都可以帮助如何将 kafka 消费者组设置为非活动/活动状态吗?
【问题讨论】:
标签: apache-kafka kafka-consumer-api
我最大的问题是,我们在 kafka 中是否有一个称为 consumer group 的概念来不活跃/活跃。
我不确定如何在我的本地 kafka 服务器中实现这一点。
任何人都可以帮助如何将 kafka 消费者组设置为非活动/活动状态吗?
【问题讨论】:
标签: apache-kafka kafka-consumer-api
如果你有 Confluent 控制中心,你可以看到消费者部分,如果“消费者数量”列为 0,则消费者组处于非活动状态,反之亦然
【讨论】:
如果您有一个 active Consumer 正在读取消息,并且偏移量正在提交回 Kafka,那么您可以自信地说,就 Consumer Group 而言,它处于活动状态被关注到。
如果组正在重新平衡,消费者会定期死亡,或者不再有任何消费者从某个主题读取,那么它就处于非活动状态。
【讨论】:
Error: Assignments can only be reset if the group 'some-group' is inactive, but the current state is PreparingRebalance.