我使用的是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
相反。如果我这样做了会发生什么?
如果发生任何一种情况,将执行压缩:
- 脏净比和
min.compaction.lag
均满足
或
max.compaction.lag
已完成
所以min.compaction.lag.ms
大于max.compaction.lag.ms
是可以的。因为它们在两种不同的条件下使用,并且不相互矛盾。
顺便说一句,你最后选择了什么?结果如何?