Kafka 无论消息是否被消费,都会保留所有消息。两种策略可删除旧数据:

  1. 基于时间:log.retention.hours=168 (保留 168 小时)
  2. 基于大小:log.retention.bytes=1073741824 (保留 1GB)

Kafka 读取特定消息的时间复杂度为 O(1),与文件大小无关,因此删除过期文件与 Kafka 性能无关。

Topic 创建与删除

Topic 创建的序列图请参考 RK3288 Technical Reference Manual 图 5。