为什么该主题是COMPACT而不是DELETE+COMPACT?
有具体原因吗?
因为,如果您运行一个组使用者,并且它停止了一段时间,在重新启动组使用者之后,它应该从上次消耗的偏移量开始消耗。
__consumer_offsets
主题为您的组使用者保留其所使用的每个分区的最后偏移量。因此,如果它从卡夫卡中删除,就没有任何痕迹。
cleanup.policy = compact
意味着它将保留密钥的最新消息很长时间,直到你按下它。
因此,像这样,您的Grooo消费者的最后一次偏移在__consumer.offsets
中是安全的,因为它是压缩的。