【发布时间】:2021-10-24 08:52:16
【问题描述】:
如果我理解正确,cleanup.policy 的默认值是 delete,这意味着旧段将在通过配置 log.retention.hours 和 log.retention.bytes 限制保留时间或大小时被丢弃。
问:
在这种情况下,日志中可能有多个具有不同值的相同键的消息是否正确? null 值(墓碑?)的消息会发生什么,这也是默认值?
如果是这样,如果我理解正确,那么这里有 delete 清理策略,它定义了由 delete.retention.ms 配置的每条记录保留,这既保证最后一个密钥存在,也将删除所有带有 null 的消息价值?
问:
-
如果是这样,即使
delete.retention.ms配置为1ms,我还能看到带有null值的消息吗? -
为了删除日志中的所有消息,我应该更改哪个配置?有可能吗?
-
retention.ms和delete.retention.ms是否以某种方式连接?如果是这样 - 采用何种保留政策以及如何实施?
谢谢!
【问题讨论】:
标签: apache-kafka