小编use*_*577的帖子

kafka保留策略没有按预期工作

我想要某个kafka主题只保留1天的数据。但如果我们继续向主题(活动)发送数据,它似乎根本不会删除任何数据。我尝试了主题端参数(retention.ms)和服务器端:

    log.retention.hours=1 or log.retention.ms= 86400000 
    cleanup.policy=delete
Run Code Online (Sandbox Code Playgroud)

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

那么,对于活动主题来说,仅保留数据一段时间的正确配置是什么?

apache-kafka

6
推荐指数
2
解决办法
4029
查看次数

标签 统计

apache-kafka ×1