| 语义 | 同一 key 只保留最后一个 value（更早的最终被清理） |
|---|---|
| 场景 | KTable changelog、配置变更流、CDC 明细表 |
| 相关参数 | min.cleanable.dirty.ratio、delete.retention.ms、segment.ms |
创建压实主题
创建压实主题
kafka-topics.sh --bootstrap-server localhost:9092 \
--create --topic user-profile-compact \
--partitions 3 --replication-factor 3 \
--config cleanup.policy=compact \
--config min.cleanable.dirty.ratio=0.3压实只保证最终收敛：key 的旧值在被清理前仍然可以被读到，重放时要按 key 去重取最新。