Hi, 可以描述下你的业务场景么? 为什么一定要去获取 key 的信息呢,因为按照我的理解,一般来说 key 的信息一般在 value 中也有。
Best, Jark On Tue, 7 Jul 2020 at 17:17, op <520075...@qq.com> wrote: > 感谢 > > > > > ------------------ 原始邮件 ------------------ > 发件人: "Leonard Xu"<xbjt...@gmail.com>; > 发送时间: 2020年7月7日(星期二) 下午5:15 > 收件人: "user-zh"<user-zh@flink.apache.org>; > > 主题: 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.> > ; > > > 在 2020年7月7日,17:01,op <520075...@qq.com> 写道: > > > > hi: > > &nbsp; flink sql 写kafka表的时候可以指定消息的key吗? > > 看官网的kafka connector没有找到消息key相关的说明 > > 如果可以的话,如何指定? > > &nbsp;谢谢