Kafka 主题保留与压缩策略（Retention、Log Compaction、cleanup.policy）
设计 Kafka 主题的保留与压缩策略，合理配置 `cleanup.policy=delete/compact`，并验证可靠性与成本的平衡。
工程实践
Kafka 主题保留与压缩策略（Retention、Compaction 与验证）
配置Kafka主题的时间/大小保留策略与日志压缩，按业务键保留最新值并降低存储成本，提供参数示例与端到端验证方法。
Kafka Topic 保留与压缩策略配置指南
"配置主题的保留与压缩策略（Delete/Compact），提供命令与参数说明，保障日志与状态主题的高效管理。"
Kafka Streams Exactly-Once 处理语义实践
"在 Kafka Streams 中启用 Exactly-Once v2，提供配置与示例代码，保障端到端处理一致性。"
Kafka Streams Exactly-Once v2 事务处理与状态容错实践
配置 Kafka Streams 使用 Exactly-Once v2 事务保障端到端一致性，示例构建拓扑并验证状态容错与重启恢复。
Kafka Schema Registry与兼容策略实践
使用Schema Registry治理消息模式并设置兼容策略，提供可验证的API与CLI示例，保障演进稳定与下游兼容。
Kafka Schema Registry 兼容性与模式演进实践
配置全局与主题级兼容性策略，注册 Avro 模式并验证兼容性，安全演进事件结构。
Kafka Producer 幂等与事务写入实践
配置 Kafka Producer 幂等与事务写入，保证端到端一致性与去重；示例展示事务开启、发送与提交流程。
压缩与模式演进治理（2025）
Kafka Connect S3 Sink 分区/压缩与模式演进治理（2025）一、分区与命名分区：按时间/主题/分区生成层级；支持查询按需加载。命名：统一文件名与路径；避免碎片与小文件。二、压缩与格式压缩：使用 `gzip/zstd`；平衡 CPU 与存储成本。格式：Avro/Parquet/JS
Kafka Connect Elasticsearch Sink 连接器写入索引实践
使用 Elasticsearch Sink 连接器将 Kafka 主题写入索引，配置连接与写入模式、键处理与容错策略。
