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 Shuai Xia <jk...@dingtalk.com.INVALID> on 2021/01/20 06:42:36 UTC

回复：Flink 1.11 SQL可以支持kafka动态分区发现么？

Hi,看下FlinkKafkaConsumerBase内有没有使用,有的话就是支持的


------------------------------------------------------------------
发件人：sunfulin <su...@163.com>
发送时间：2021年1月20日(星期三) 14:40
收件人：user-zh <us...@flink.apache.org>
主　题：Flink 1.11 SQL可以支持kafka动态分区发现么？


hi，
各位大神，请教下，1.11的sql作业，如何能实现动态分区发现呐？我在1.12的文档里发现有个参数可以设置，但是1.11的版本里貌似没有。想确认下能否支持？




--
发自我的网易邮箱手机智能版

Re: 回复：Flink 1.11 SQL可以支持kafka动态分区发现么？

Posted by zhisheng <zh...@gmail.com>.
1.11 文档里面没有，那么估计就不支持了，可以看下 1.12 如何实现的，然后把这个 patch 打在内部自己的 flink 版本里面

sunfulin <su...@163.com> 于2021年1月20日周三 下午2:53写道：

>
> 我看下这个源码，貌似是有这个参数。还不确定SQL ddl里配置会不会生效，回头验证下。
>
>
>
>
> --
> 发自我的网易邮箱手机智能版
> <br/><br/><br/>
>
>
> ----- Original Message -----
> From: "Shuai Xia" <jk...@dingtalk.com.INVALID>
> To: user-zh <us...@flink.apache.org>, sunfulin0321 <sunfulin0321@163.com
> >
> Sent: Wed, 20 Jan 2021 14:42:36 +0800
> Subject: 回复：Flink 1.11 SQL可以支持kafka动态分区发现么？
>
> Hi,看下FlinkKafkaConsumerBase内有没有使用,有的话就是支持的
>
>
> ------------------------------------------------------------------
> 发件人：sunfulin <su...@163.com>
> 发送时间：2021年1月20日(星期三) 14:40
> 收件人：user-zh <us...@flink.apache.org>
> 主 题：Flink 1.11 SQL可以支持kafka动态分区发现么？
>
>
> hi，
>
> 各位大神，请教下，1.11的sql作业，如何能实现动态分区发现呐？我在1.12的文档里发现有个参数可以设置，但是1.11的版本里貌似没有。想确认下能否支持？
>
>
>
>
> --
> 发自我的网易邮箱手机智能版

Re:回复：Flink 1.11 SQL可以支持kafka动态分区发现么？

Posted by sunfulin <su...@163.com>.
我看下这个源码，貌似是有这个参数。还不确定SQL ddl里配置会不会生效，回头验证下。




--
发自我的网易邮箱手机智能版
<br/><br/><br/>


----- Original Message -----
From: "Shuai Xia" <jk...@dingtalk.com.INVALID>
To: user-zh <us...@flink.apache.org>, sunfulin0321 <su...@163.com>
Sent: Wed, 20 Jan 2021 14:42:36 +0800
Subject: 回复：Flink 1.11 SQL可以支持kafka动态分区发现么？

Hi,看下FlinkKafkaConsumerBase内有没有使用,有的话就是支持的


------------------------------------------------------------------
发件人：sunfulin <su...@163.com>
发送时间：2021年1月20日(星期三) 14:40
收件人：user-zh <us...@flink.apache.org>
主　题：Flink 1.11 SQL可以支持kafka动态分区发现么？


hi，
各位大神，请教下，1.11的sql作业，如何能实现动态分区发现呐？我在1.12的文档里发现有个参数可以设置，但是1.11的版本里貌似没有。想确认下能否支持？




--
发自我的网易邮箱手机智能版