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

Question

我使用的是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相反。但是如果我这样做了，会发生什么呢？

Answer 1

如果发生以下任一情况，则将执行压缩：

1. 脏/干净比率和min.compaction.lag的条件都已满足

或

1. max.compaction.lag is fulfilled

因此，让min.compaction.lag.ms比max.compaction.lag.ms更大也是可以的。因为它们在两个不同的条件下使用，并且彼此不矛盾。

顺便说一句，你最终选择了什么？你的结果是什么？