apache-kafka - 为什么主题__consumer_offsets 的cleanup.policy 是COMPACT？

Question

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

有具体原因吗？

标签： apache-kafka

Answer 1

因为，如果你运行一个组消费者，并且它停止了一段时间，在重新声明组消费者之后，它应该从它被消费的最后一个偏移量开始消费。

__consumer_offsets主题为您使用的每个分区保留您的组消费者的最后偏移量。因此，如果它从 kafka 中删除，则没有任何痕迹。

cleanup.policy = compact意味着它将保留密钥的最新消息，直到您将其删除为止。

所以，像这样，你的 grouo 消费者的最后一个偏移量是安全的，__consumer.offsets因为它被压缩了。