Kafka 无论消息是否被消费,都会保留所有消息。两种策略可删除旧数据:
- 基于时间:
log.retention.hours=168
(保留 168 小时) - 基于大小:
log.retention.bytes=1073741824
(保留 1GB)
Kafka 读取特定消息的时间复杂度为 O(1),与文件大小无关,因此删除过期文件与 Kafka 性能无关。
Topic 创建与删除
Topic 创建的序列图请参考 RK3288 Technical Reference Manual 图 5。
Kafka 无论消息是否被消费,都会保留所有消息。两种策略可删除旧数据:
log.retention.hours=168
(保留 168 小时)log.retention.bytes=1073741824
(保留 1GB)Kafka 读取特定消息的时间复杂度为 O(1),与文件大小无关,因此删除过期文件与 Kafka 性能无关。
Topic 创建的序列图请参考 RK3288 Technical Reference Manual 图 5。