"Apache Kafka 消费组与投递语义：有序性、幂等与事务"
"梳理 Kafka 的分区有序性、幂等生产与事务性消费/提交策略，给出可验证的配置示例。"
kafka
Debezium CDC 数据变更捕获（Kafka Connect、事务边界与幂等）
使用 Debezium 构建 CDC 流水线，明确事务边界与顺序保证，结合幂等处理与去重策略，提供验证与观测方法。
Kafka Connect SMT：数据清洗与标准化
使用 Kafka Connect 的 SMT 在管道中进行字段重命名、过滤与规范化，降低下游适配成本。
"Kafka Connect 与 Debezium MySQL CDC 实战"
"使用 Debezium 在 Kafka Connect 中捕获 MySQL 变更，提供 Connector 配置与主题命名规范，适合增量数据管道。"
Kafka KRaft与ZooKeeper迁移治理
评估并迁移到 KRaft 控制面，理解架构差异与滚动升级策略，降低复杂度与运维成本。
Kafka MirrorMaker 2多集群复制治理
基于 MM2 的 Connect 框架进行跨集群主题与偏移复制，治理命名、心跳与故障切换策略。
Kafka MirrorMaker 2多集群灾备与延迟治理
使用 MM2 在多集群间进行主题镜像与灾备，规范命名与拓扑、延迟与一致性治理，保障跨地域数据与消费安全。
Kafka Schema Registry：Avro/Protobuf/JSON Schema演进
使用 Schema Registry 管理消息模式，比较三种模式的兼容策略与演进路径，保障生产稳定。
Kafka Streams状态存储与RocksDB调优
掌握 Kafka Streams 的状态存储与恢复机制，调优 RocksDB/缓存与日志，提升稳定性与延迟表现。
Kafka 主题保留与压缩策略（Retention、Compaction 与验证）
配置Kafka主题的时间/大小保留策略与日志压缩，按业务键保留最新值并降低存储成本，提供参数示例与端到端验证方法。
