我在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
是否需要设置其他主题配置?任何帮助或指点将不胜感激。
暂无答案!
目前还没有任何答案,快来回答吧!