kafka
Kafka事务与Exactly-Once处理实践
在Kafka中通过事务与幂等生产者实现Exactly-Once处理,提供可验证的客户端配置与操作命令,保障端到端一致性。
Kafka 主题保留与压缩策略(Retention、Log Compaction、cleanup.policy)
设计 Kafka 主题的保留与压缩策略,合理配置 `cleanup.policy=delete/compact`,并验证可靠性与成本的平衡。
Kafka 事务与精确一次语义(Idempotent Producer、Transactional 与验证)
通过幂等生产与事务边界实现Kafka精确一次语义,配置生产者与消费者参数,并提供端到端的验证方案以避免重复写入与脏读。
Kafka MirrorMaker 2多集群灾备与延迟治理
使用 MM2 在多集群间进行主题镜像与灾备,规范命名与拓扑、延迟与一致性治理,保障跨地域数据与消费安全。
Kafka MirrorMaker 2多集群复制治理
基于 MM2 的 Connect 框架进行跨集群主题与偏移复制,治理命名、心跳与故障切换策略。
Kafka事务与正好一次语义治理
通过生产者事务与幂等确保正好一次语义,结合 `read_committed` 与事务性偏移提交,保障处理链无重复与不丢失。
Kafka KRaft与ZooKeeper迁移治理
评估并迁移到 KRaft 控制面,理解架构差异与滚动升级策略,降低复杂度与运维成本。
