多应用+插件架构,代码干净,二开方便,首家独创一键云编译技术,文档视频完善,免费商用码云13.8K 广告
无论消息是否被消费,kafka 都会保留所有消息。有两种策略可以删除旧数据: 1)基于时间:`log.retention.hours=168` 2)基于大小:`log.retention.bytes=1073741824` 因为 Kafka 读取特定消息的时间复杂度为 O(1),即与文件大小无关,所以这里删除过期文件与提高 Kafka 性能无关。