el.chen |
>| 发送日期 | 2022年12月5日 18:24 |
>| 收件人 | user-zh@flink.apache.org |
>| 主题 | flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？ |
>flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？仿照kafka source表添加了 scan.startup.mode
>参数会报非法参数
hi
Upsert-kafka 不支持指定消费者位置，默认是从 earliest 位置开始消费的，你可以自己修改代码支持 scan.startup.mode 参数。
Best
JasonLee
回复的原邮件
| 发件人 | casel.chen |
| 发送日期 | 2022年12月5日 18:24 |
| 收件人 | user-zh@flink.apache.org |
| 主题 | flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？ |
flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？仿照
flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？仿照kafka source表添加了 scan.startup.mode
参数会报非法参数
