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

[JasonLee]

hi

参数是这么写的没错 'scan.startup.mode' = 'earliest-offset' 你确定你是用的新的groupid吗
我这里测试是可以的从头开始消费的 不知道是不是你测试的方法不对



--
Sent from: http://apache-flink.147419.n8.nabble.com/