标签

#Exactly-Once

共 4 篇文章

【字节跳动】Kafka 与 Flink 如何实现 Exactly-Once

字节跳动大数据一面真题。Kafka 靠幂等生产者和事务做到单分区及跨分区 Exactly-Once，Flink 靠两阶段提交 checkpoint 协议实现端到端语义。

91学AI·7 阅读

拆解"端到端"的三段语义，讲清 Kafka 事务 + 位移原子提交的内环方案、Flink 两阶段提交检查点的外环方案，以及什么时候该退回业务幂等。

91学AI·7 阅读

幂等解决单分区内的重复写入（PID+序列号去重），事务解决跨分区跨主题的原子写，两阶段提交 + 事务协调器，并能说出各自的边界和代价。

91学AI·8 阅读

区分内部状态一致性与端到端 Exactly-Once，讲清两阶段提交 sink 的预提交/提交/中止流程，以及 Kafka、MySQL 等常见 sink 的一致性实现方式。

91学AI·7 阅读