Kafka 事务与精确一次语义（Idempotent Producer、Transactional 与验证）
通过幂等生产与事务边界实现Kafka精确一次语义，配置生产者与消费者参数，并提供端到端的验证方案以避免重复写入与脏读。
kafka
NATS JetStream与Kafka对比：轻量消息与流存储选型
对比 NATS JetStream 与 Kafka 的架构与语义，理解轻量消息与流存储的适配场景与一致性与成本权衡。
Kafka KRaft与ZooKeeper迁移治理
评估并迁移到 KRaft 控制面，理解架构差异与滚动升级策略，降低复杂度与运维成本。
Kafka事务与Exactly-Once：生产/消费端一致性治理
通过幂等生产与事务语义实现端到端一次性处理，规范消费者隔离与处理拓扑的错误恢复。
Kafka事务与正好一次语义治理
通过生产者事务与幂等确保正好一次语义，结合 `read_committed` 与事务性偏移提交，保障处理链无重复与不丢失。
Kafka MirrorMaker 2多集群复制治理
基于 MM2 的 Connect 框架进行跨集群主题与偏移复制，治理命名、心跳与故障切换策略。
Kafka连接器与Schema Registry治理：兼容性与演进
以 Connect 与 Schema Registry 为核心，规范主题与模式演进，构建稳健的数据集成与传输治理。
Kafka 主题保留与压缩策略（Retention、Compaction 与验证）
配置Kafka主题的时间/大小保留策略与日志压缩，按业务键保留最新值并降低存储成本，提供参数示例与端到端验证方法。
Kafka 主题保留与压缩策略（Retention、Log Compaction、cleanup.policy）
设计 Kafka 主题的保留与压缩策略，合理配置 `cleanup.policy=delete/compact`，并验证可靠性与成本的平衡。
