我有一个带有autoscaler的服务，每个示例都需要在一个单独的用户组中，我通过随机生成一个用户组名来实现这一点 group-id: my-service-${random.uuid} . 我想知道如果所有的消费者都消失了，一个消费群体会发生什么。我注意到在confluent platform中，我有许多消费者群体，但没有任何消费者。
没有消费者的消费群体能存在多久？
如何配置要在删除服务后（例如，5分钟后）删除的用户组（我希望删除的是组，而不仅仅是删除的偏移量）？
我有一个带有autoscaler的服务，每个示例都需要在一个单独的用户组中，我通过随机生成一个用户组名来实现这一点 group-id: my-service-${random.uuid} . 我想知道如果所有的消费者都消失了，一个消费群体会发生什么。我注意到在confluent platform中，我有许多消费者群体，但没有任何消费者。
没有消费者的消费群体能存在多久？
如何配置要在删除服务后（例如，5分钟后）删除的用户组（我希望删除的是组，而不仅仅是删除的偏移量）？
1条答案
按热度按时间qnyhuwrf1#
在Kafka你有配置
offsets.retention.minutes在经纪人层面：offset.retention.minutes：在消费组失去所有消费者（即变为空）后，其偏移量将保留此保留期，然后丢弃。对于独立使用者（使用手动分配），偏移量将在上次提交时间加上此保留期后过期。”
此配置默认为7天。请参阅broker配置概述中的所有详细信息。
adminclient中还有一个api，允许您删除特定的ConsumerGroup。我在另一个答案中用一些代码解释了这个过程。
由于Confluent6.x，您还可以使用ConfluentControl center（使用RESTAPI）轻松删除过时的ConsumerGroup。