请教大佬一个在flink调用kafka数据源时'scan.startup.mode'参数的使用问题

Thu, 13 Aug 2020 21:44:56 -0700 

在flink作业中从kafka数据源获取数据，将 参数设置为'scan.startup.mode' = 'earliest-offset',
检测flink运行结果时，发现只抽取了kafka中的newest数据，没有获取到oldest数据。
不知道是不是我这里'scan.startup.mode' 参数用的不对。
Flink 版本1.11.1 kafka版本 2.6.0

回复