Flink如何保存Offset

时间 2019-12-12

标签 flink 如何保存 offset 繁體版

原文原文链接

Flink对Offset的管理，有两种方式： 1.Checkpointing disabled 彻底依赖于kafka自身的API 2.Checkpointing enabled 当checkpoint作完的时候，会将offset提交给kafka or zk 本文只针对于第二种，Checkpointing enabledweb FlinkKafkaConsumerBase中的 notifyCheck

>>阅读原文<<

1. my.ini不能保存，如何保存？
2. sparkStreaming的offset保存在redis中
3. spark createDirectStream保存kafka offset(JAVA实现)
4. python如何保存矩阵，保存matrix,保存numpy.ndarray
5. 如何保存联系人
6. session 如何保存会话
7. R如何保存图片
8. gns3如何保存配置
9. 微信access_token如何保存
10. 如何保存Keras模型
更多相关文章...
• XSD 如何使用? - XML Schema 教程
• 如何伪造ARP响应？ - TCP/IP教程
• Flink 数据传输及反压详解
• 三篇文章了解 TiDB 技术内幕——说存储

最新文章

1. 1.2 Illustrator多文档的几种排列方式
2. 5.16--java数据类型转换及杂记
3. 性能指标
4. （1.2）工厂模式之工厂方法模式
5. Java记录 -42- Java Collection
6. Java记录 -42- Java Collection
7. github使用
8. Android学习笔记（五十）：声明、请求和检查许可
9. 20180626
10. 服务扩容可能引入的负面问题及解决方法

本站公众号

欢迎关注本站公众号,获取更多信息

1. my.ini不能保存，如何保存？
2. sparkStreaming的offset保存在redis中
3. spark createDirectStream保存kafka offset(JAVA实现)
4. python如何保存矩阵，保存matrix,保存numpy.ndarray
5. 如何保存联系人
6. session 如何保存会话
7. R如何保存图片
8. gns3如何保存配置
9. 微信access_token如何保存
10. 如何保存Keras模型

>>更多相关文章<<