数据
Kafka事务与正好一次语义治理
通过生产者事务与幂等确保正好一次语义,结合 `read_committed` 与事务性偏移提交,保障处理链无重复与不丢失。
Kafka事务与Exactly-Once:生产/消费端一致性治理
通过幂等生产与事务语义实现端到端一次性处理,规范消费者隔离与处理拓扑的错误恢复。
Kafka Streams状态存储与RocksDB调优
掌握 Kafka Streams 的状态存储与恢复机制,调优 RocksDB/缓存与日志,提升稳定性与延迟表现。
Kafka Streams与Flink对比:内嵌流处理与分布式引擎
对比内嵌于应用的 Kafka Streams 与分布式流引擎 Flink 的能力与适配场景,指导工程选型。
Kafka MirrorMaker 2多集群灾备与延迟治理
使用 MM2 在多集群间进行主题镜像与灾备,规范命名与拓扑、延迟与一致性治理,保障跨地域数据与消费安全。
Kafka MirrorMaker 2多集群复制治理
基于 MM2 的 Connect 框架进行跨集群主题与偏移复制,治理命名、心跳与故障切换策略。
