| 源 | 可重放位点 |
|---|---|
| 计算 | 检查点状态 |
| 写入 | 事务或幂等 |
| 验证 | 故障注入测试 |
两阶段提交写入
两阶段提交写入
sinkBuilder.build();
// FlinkKafkaProducer 与 StreamingFileSink 提供 exactly-once 语义
// 湖表写入可用 Iceberg/Hudi 的事务提交配合检查点完成
stream.sinkTo(icebergSink).uid('iceberg-sink');幂等写入要保证主键唯一：按业务主键覆盖 + 保留版本号，重复消费不会产生重复行。