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! >
