kafka
Kafka事务与Exactly-Once处理实践
在Kafka中通过事务与幂等生产者实现Exactly-Once处理,提供可验证的客户端配置与操作命令,保障端到端一致性。
Kafka 事务与精确一次语义(Idempotent Producer、Transactional 与验证)
通过幂等生产与事务边界实现Kafka精确一次语义,配置生产者与消费者参数,并提供端到端的验证方案以避免重复写入与脏读。
Kafka MirrorMaker 2多集群灾备与延迟治理
使用 MM2 在多集群间进行主题镜像与灾备,规范命名与拓扑、延迟与一致性治理,保障跨地域数据与消费安全。
Kafka 主题保留与压缩策略(Retention、Log Compaction、cleanup.policy)
设计 Kafka 主题的保留与压缩策略,合理配置 `cleanup.policy=delete/compact`,并验证可靠性与成本的平衡。
Kafka 事务与端到端一致性(2025)
Kafka 事务与端到端一致性(2025)端到端一致性需要在生产、消费与持久化之间协同保障。一、幂等生产与事务幂等生产:避免重复消息;配置生产者幂等与重试。事务:将多个写入合并为原子操作,保障一致性。二、Exactly-once (EOS)EOS:在流处理与下游写入之间实现 Exactly-once
Strimzi 在 Kubernetes 部署 Kafka 高可用实践
基于 Strimzi Operator 部署高可用 Kafka 集群,提供持久化与滚动升级的可验证方案
