FlinkFlink 模拟 kafka 消费重启后 能接着读取 保存状态信息

Posted 2021-09-08 九师兄

1.概述

参考视频教程：

P61 60需求-使用OperatorState的记录文件偏移量
15:14

P62 61自定义并行Source并结合OperatorState
30:34

P63 62深入理解OperatorState 46:46

我们想做一个程序，来模拟kafka读取时数据。
假设一个目录下我们有一些文件

[lcc@lcc ~/temp/file]$ ll
-rw-r--r--  1 lcc  staff   14  8