为什么主题__consumer_offset的cleanup.policy是COMPACT



为什么该主题是COMPACT而不是DELETE+COMPACT?

有具体原因吗?

因为,如果您运行一个组使用者,并且它停止了一段时间,在重新启动组使用者之后,它应该从上次消耗的偏移量开始消耗。

__consumer_offsets主题为您的组使用者保留其所使用的每个分区的最后偏移量。因此,如果它从卡夫卡中删除,就没有任何痕迹。

cleanup.policy = compact意味着它将保留密钥的最新消息很长时间,直到你按下它。

因此,像这样,您的Grooo消费者的最后一次偏移在__consumer.offsets中是安全的,因为它是压缩的。

最新更新