0

我使用的是 Kafka 2.2.0,因此max.compaction.lag.ms尚不提供按主题配置的选项。

在全球范围内,我有log.cleaner.max.compaction.lag.ms=86400000(一天):

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

我可以设置min.compaction.lag.ms259200000(三天),但似乎与较小的log.cleaner.max.compaction.lag.ms. 如果我仍然这样做会发生什么?

4

1 回答 1

0

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

  1. 脏/净比率的两个条件min.compaction.lag都满足

或者

  1. max.compaction.lag已完成

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

BTW,你最后选择了什么?你的结果是什么?

于 2021-03-14T11:04:39.020 回答