提问者:小点点

删除基础 Kafka 主题后,Kafka 服务器上的 Kafka 使用者组会发生什么情况?


假设我有Kafka主题的汽车

我还有一个订阅了汽车主题的消费者组cares-消费者cares-消费者消费者组目前位于偏移量89。

现在删除汽车话题后汽车消费者群体会发生什么变化?它也会被删除吗?

否则,当我重新创建< code >汽车主题时会发生什么?< code >汽车-消费者消费者群体是否仍处于偏移量89?


共1个答案

匿名用户

它不会被立即删除。

__consumer_offsets 主题将组名维护为记录键,并将主题分区偏移量存储在值中。如果没有对同一组的提交,它最终将被压缩。

换句话说,如果该组订阅了 cars 主题和其他主题,则只要其他主题的提交继续,汽车主题的已提交偏移量就会保留(因为它们都按组键分组)。因此,如果为不仅仅包含该主题的组重新创建主题,则可能会看到旧的偏移量。但是,如果偏移量如您所说为 89,并且在下一次消费者投票中不会立即可用,那么 auto.offset.reset 将生效,要么转到主题的开头,要么转到主题的结尾