You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2022/12/05 10:24:12 UTC

flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？

flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？仿照kafka source表添加了 scan.startup.mode 参数会报非法参数

Re:回复：flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？

Posted by "casel.chen" <ca...@126.com>.

好吧，难怪我没找到设置开始消费位置的参数，谢谢！

















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

回复：flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？

Posted by JasonLee <17...@163.com>.

hi


Upsert-kafka 不支持指定消费者位置，默认是从 earliest 位置开始消费的，你可以自己修改代码支持 scan.startup.mode 参数。


Best
JasonLee


---- 回复的原邮件 ----
| 发件人 | casel.chen<ca...@126.com> |
| 发送日期 | 2022年12月5日 18:24 |
| 收件人 | user-zh@flink.apache.org<us...@flink.apache.org> |
| 主题 | flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？ |
flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？仿照kafka source表添加了 scan.startup.mode 参数会报非法参数