加速删除具有相同密钥的旧记录(日志压缩主题)

7gyucuyw  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(193)

我在mac上用默认服务器设置运行kafka broker(2.12版)。我创建了一个日志压缩主题,配置如下-

Configs: cleanup.policy=compact,segment.bytes=1073741824,delete.retention.ms=100,segment.ms=100

我制作了三张键/值相同的唱片。5分钟后(log.retention.check.interval.ms=300000),我从头开始读这个主题。我在主题中看到以下三条记录。我期待一张唱片。

key1:aaa
key1:aaa
key1:aaa

10分钟后,我生成了一个键相同、值不同的记录(键1:bbb)。然后在5分钟后,从头开始读这个主题,结果是下面两个记录。我期待一张唱片(key1:bbb)。

key1:aaa
key1:bbb

是否需要设置其他主题配置?任何帮助或指点将不胜感激。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题