我想要某个kafka主题只保留1天的数据。但如果我们继续向主题(活动)发送数据,它似乎根本不会删除任何数据。我尝试了主题端参数(retention.ms)和服务器端:
log.retention.hours=1 or log.retention.ms= 86400000
cleanup.policy=delete
Run Code Online (Sandbox Code Playgroud)
但如果我们继续向其发送数据,它似乎不适用于活动主题。只有当我们停止向主题发送数据时,它才会遵循保留策略。
那么,对于活动主题来说,仅保留数据一段时间的正确配置是什么?
apache-kafka ×1