apache-kafka - kafka 保留政策没有按预期工作

Question

我希望某个 kafka 主题只保留 1 天的数据。但是如果我们继续向主题(事件)发送数据，它似乎根本没有删除任何数据。我尝试了主题端参数(retention.ms)和服务器端:

    log.retention.hours=1 or log.retention.ms= 86400000 
    cleanup.policy=delete

但是如果我们继续向它发送数据，它似乎不适用于活跃的主题。只有当我们停止向主题发送数据时，它才会遵循保留策略。

那么，事件主题的正确配置是什么，只保留一段时间的数据？

Answer 1

Kafka 只删除被动日志段。您必须调整其中之一 log.segment.bytes或 log.roll.ms将主动日志段滚动到被动日志段。引用 Broker configuration想要查询更多的信息。