Flink exactly once sink 实现

2025-07-19
北京
本文字数：516 字
阅读完需：约 2 分钟

public class ExactlyOnceSink extends TwoPhaseCommitSinkFunction<String, Transaction, Void> {        // 1. 开始事务    @Override    protected Transaction beginTransaction() {        return externalSystem.beginTransaction(); // 创建外部系统事务    }
    // 2. 写入数据（在事务中）    @Override    protected void invoke(Transaction transaction, String value, Context context) {        externalSystem.writeInTransaction(transaction, value);    }
    // 3. 预提交（检查点完成前）    @Override    protected void preCommit(Transaction transaction) {        externalSystem.prepareCommit(transaction);    }
    // 4. 正式提交（检查点完成后）    @Override    protected void commit(Transaction transaction) {        externalSystem.commit(transaction);    }
    // 5. 中止事务    @Override    protected void abort(Transaction transaction) {        externalSystem.rollback(transaction);    }}