Kafka的Log Compaction不是Java代码主动删除，而是Broker后台LogCleaner线程根据配置自动执行：需显式启用log.cleaner.enable=true和cleanup.policy=compact，消息必须带稳定非空key，value为最新状态或null（墓碑），并通过min.cleanable.dirty.ratio等参数调优压缩及时性。
Kafka 的 Log Compaction 不是靠 Java 代码主动“删除”旧数据，而是通过配置驱动 Broker 自动完成的后台压缩过程。Java 端只需确保消息符合压缩前提（比如带稳定非空 key），真正清理动作由 Kafka 自身的日志清理线程（LogCleaner）执行。
必须开启并确认关键配置
Compaction 不会自动生效，需显式启用且多个开关协同：
-
Broker 级开启 cleaner：确保
log.cleaner.enable=true（默认为 true，但生产环境建议显式设置） -
Topic 级指定策略：创建或修改 topic 时设
cleanup.policy=compact（不能只依赖全局默认；若还需保留过期段，可设为delete,compact） -
禁用 delete 策略干扰：若只想要纯 compact 行为，避免同时启用基于时间/大小的
log.retention.*参数，否则可能触发段级删除而非 key 级压缩
消息必须满足压缩前提
只有符合条件的消息才会被纳入压缩流程：
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
-
每条消息必须有非空 key：Producer 发送时使用
ProducerRecord<K,V>构造器传入明确 key（如用户 ID、设备编号），key 为 null 的消息会被跳过或丢弃 -
key 需保持稳定：同一实体的状态变更应复用相同 key（例如订单状态更新始终用
"order_123"），否则 Kafka 无法识别为“同一键的历史版本” -
value 可为空（墓碑消息）：发送
value=null表示该 key 对应的数据已被逻辑删除，压缩后该 key 将从日志中彻底移除
调优压缩及时性与效果
默认参数可能导致压缩滞后，影响最新状态可见性：
立即学习“Java免费学习笔记（深入）”；
-
降低触发阈值：减小
min.cleanable.dirty.ratio（默认 0.5），例如设为0.1，让 cleaner 更早介入脏段 -
控制墓碑保留窗口：设置
delete.retention.ms（默认 24 小时），决定 tombstone 消息在被真正清理前的最短保留时间，保障消费者有足够时间读到“已删除”信号 -
增加清理资源：适当调高
log.cleaner.threads（默认 1），尤其在多 topic 或高吞吐场景下
验证是否生效
不依赖 Java 代码验证，而是检查 Kafka 运行态：
- 用
kafka-topics.sh --describe查看 topic 的Cleanuppolicy是否为compact - 观察日志目录下 segment 文件变化：压缩后会出现新命名的
.cleaned段文件，并替换旧段 - 用
kafka-console-consumer.sh从头消费，确认每个 key 只出现一次且 value 是最新值（注意要加--from-beginning并确保 group.id 未提交 offset）
