按理说这个模式即使是老的group id，也会忽略在kafka中保存的offset的。 你是从checkpoint恢复的任务么？从checkpoint恢复的offset的会覆盖这个配置。
JasonLee <17610775...@163.com> 于2020年8月14日周五 下午10:02写道： > hi > > 参数是这么写的没错 'scan.startup.mode' = 'earliest-offset' 你确定你是用的新的groupid吗 > 我这里测试是可以的从头开始消费的 不知道是不是你测试的方法不对 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ -- Best, Benchao Li
