企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持知识库和私有化部署方案 广告
无论消息是否被消费,kafka 都会保留所有消息。有两种策略可以删除旧数据: 1)基于时间:`log.retention.hours=168` 2)基于大小:`log.retention.bytes=1073741824` 因为 Kafka 读取特定消息的时间复杂度为 O(1),即与文件大小无关,所以这里删除过期文件与提高 Kafka 性能无关。