确定删除吗?
1.Apache Kafka x Apache Flink·
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.• •
12.•
13.
14.
15.•
16.•
17.Chandy-Lamport • • •
18.Exactly Once At least once + • • • • At least once + • • • • barrier • Region Failover: FLINK- 4256 •
19.
20.• • • • •
21.• • • • •
22.
23.
24.
25.
26.
27.
28.public interface CheckpointListener { /** * This method is called as a notification once a distributed checkpoint has been completed. * * Note that any exception during this method will not cause the checkpoint to * fail any more. * * @param checkpointId The ID of the checkpoint that has been completed. * @throws Exception */ void notifyCheckpointComplete(long checkpointId) throws Exception; }
29.• •