假设我有Kafka主题的汽车
。
我还有一个订阅了汽车
主题的消费者组cares-消费者
。cares-消费者
消费者组目前位于偏移量89。
现在删除汽车话题后,
汽车消费者
群体会发生什么变化?它也会被删除吗?
否则,当我重新创建< code >汽车主题时会发生什么?< code >汽车-消费者消费者群体是否仍处于偏移量89?
它不会被立即删除。
__consumer_offsets
主题将组名维护为记录键,并将主题分区偏移量存储在值中。如果没有对同一组的提交,它最终将被压缩。
换句话说,如果该组订阅了 cars
主题和其他主题,则只要其他主题的提交继续,汽车
主题的已提交偏移量就会保留(因为它们都按组键分组)。因此,如果为不仅仅包含该主题的组重新创建主题,则可能会看到旧的偏移量。但是,如果偏移量如您所说为 89
,并且在下一次消费者投票中不会立即可用,那么 auto.offset.reset
将生效,要么转到主题的开头,要么转到主题的结尾