Okay, thanks for the info! On Fri, Jul 24, 2020 at 2:11 PM Leonard Xu <xbjt...@gmail.com> wrote:
> Hi, Kale > > Unfortunately Flink SQL does not support read/write Kafka message keys > yet, there is a FLIP[1] to discuss this feature. > > Best > Leonard Xu > [1] > https://cwiki.apache.org/confluence/display/FLINK/FLIP-107%3A+Reading+table+columns+from+different+parts+of+source+records#FLIP107:Readingtablecolumnsfromdifferentpartsofsourcerecords-Readingandwritingfromkey,value,timestamp > <https://cwiki.apache.org/confluence/display/FLINK/FLIP-107:+Reading+table+columns+from+different+parts+of+source+records#FLIP107:Readingtablecolumnsfromdifferentpartsofsourcerecords-Readingandwritingfromkey,value,timestamp> > > 在 2020年7月24日，15:01，Manas Kale <manaskal...@gmail.com> 写道： > > Hi, > How do I read/write Kafka message keys using DDL? I have not been able to > see any documentation for the same. > > Thanks! > > >
