好吧，难怪我没找到设置开始消费位置的参数，谢谢！
在 2022-12-05 18:34:49，"JasonLee" <17610775...@163.com> 写道： >hi > > >Upsert-kafka 不支持指定消费者位置，默认是从 earliest 位置开始消费的，你可以自己修改代码支持 scan.startup.mode 参数。 > > >Best >JasonLee > > >---- 回复的原邮件 ---- >| 发件人 | casel.chen<casel_c...@126.com> | >| 发送日期 | 2022年12月5日 18:24 | >| 收件人 | user-zh@flink.apache.org<user-zh@flink.apache.org> | >| 主题 | flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？ | >flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？仿照kafka source表添加了 scan.startup.mode >参数会报非法参数
