Apache Flink结合Apache Kafka实现端到端的一致性语义

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 .• •