流计算中的一致性语义定义,以及通常系统怎么支持一致性语义,Flink+Fafka如何实现端到端的一致性语义。

注脚

展开查看详情

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