申请试用
HOT
登录
注册
 
Apache Flink结合Apache Kafka实现端到端的一致性语义
Flink China中文社区
/
发布于
/
8746
人观看
流计算中的一致性语义定义,以及通常系统怎么支持一致性语义,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 .• •

0 点赞
5 收藏
15下载
确认
3秒后跳转登录页面
去登陆