当min.compact .lag.ms大于log.cleaner.max.compact .lag.ms时会发生什么?



我使用的是Kafka 2.2.0,所以每个主题配置max.compaction.lag.ms的选项还不可用。

全球我有log.cleaner.max.compaction.lag.ms=86400000(一天):

对于主题__consumer_offsets,我想延迟压缩到至少三天,以保留一些短期的历史。

我可以将min.compaction.lag.ms设置为259200000(三天),但它似乎与较小的log.cleaner.max.compaction.lag.ms相反。如果我这样做了会发生什么?

如果发生任何一种情况,将执行压缩:

  1. 脏净比和min.compaction.lag均满足

  1. max.compaction.lag已完成

所以min.compaction.lag.ms大于max.compaction.lag.ms是可以的。因为它们在两种不同的条件下使用,并且不相互矛盾。

顺便说一句,你最后选择了什么?结果如何?

相关内容

  • 没有找到相关文章

最新更新