Re: flink sql 读写写kafka表的时候可以指定消息的key吗

Tue, 07 Jul 2020 03:02:22 -0700 

Hi,

可以描述下你的业务场景么？ 为什么一定要去获取 key 的信息呢，因为按照我的理解，一般来说 key 的信息一般在 value 中也有。

Best,
Jark

On Tue, 7 Jul 2020 at 17:17, op <[email protected]> wrote:

> 感谢
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:&nbsp;"Leonard Xu"<[email protected]&gt;;
> 发送时间:&nbsp;2020年7月7日(星期二) 下午5:15
> 收件人:&nbsp;"user-zh"<[email protected]&gt;;
>
> 主题:&nbsp;Re: flink sql 读写写kafka表的时候可以指定消息的key吗
>
>
>
> Hi,
>
> 目前还不支持的，社区有一个 FLIP-107[1] 在计划做这个事情。
>
> 祝好，
> Leonard Xu
> [1]
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-107%3A+Reading+table+columns+from+different+parts+of+source+records#FLIP107:Readingtablecolumnsfromdifferentpartsofsourcerecords-Kafka:ETL:read,transformandwritebackwithkey,value.Allfieldsofthekeyarepresentinthevalueaswell.
> <
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-107%3A+Reading+table+columns+from+different+parts+of+source+records#FLIP107:Readingtablecolumnsfromdifferentpartsofsourcerecords-Kafka:ETL:read,transformandwritebackwithkey,value.Allfieldsofthekeyarepresentinthevalueaswell.&gt
> ;
>
> &gt; 在 2020年7月7日，17:01，op <[email protected]&gt; 写道：
> &gt;
> &gt; hi：
> &gt; &amp;nbsp; flink sql 写kafka表的时候可以指定消息的key吗？
> &gt; 看官网的kafka connector没有找到消息key相关的说明
> &gt; 如果可以的话，如何指定？
> &gt; &amp;nbsp;谢谢

回复