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 "Harold.Miao" <mi...@gmail.com> on 2020/07/14 07:31:45 UTC

[flink-sql] 如何在sql运行时动态修改kafka的scan.startup.mode

hi  all
现在有个需求，就是一段用sql-client提交的sql任务需要动态修改kafka的scan.startup.mode，以支持不同的消费需求。请问有什么好的办法吗？
谢谢


-- 

Best Regards,
Harold Miao

Re: [flink-sql] 如何在sql运行时动态修改kafka的scan.startup.mode

Posted by Benchao Li <li...@apache.org>.

可以尝试下1.11中引入的LIKE[1]或者是Table Hint[2]

[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql/create.html#create-table
[2]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql/hints.html

Harold.Miao <mi...@gmail.com> 于2020年7月14日周二 下午3:32写道：

> hi  all
>
> 现在有个需求，就是一段用sql-client提交的sql任务需要动态修改kafka的scan.startup.mode，以支持不同的消费需求。请问有什么好的办法吗？
> 谢谢
>
>
> --
>
> Best Regards,
> Harold Miao
>


-- 

Best,
Benchao Li