Reading/writing Kafka message keys using DDL pyFlink

[Manas Kale]

Hi,

How do I read/write Kafka message keys using DDL? I have not been able to see any documentation for the same.

Thanks!

[Leonard Xu]

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

在 2020年7月24日，15:01，Manas Kale <[hidden email]> 写道：

Hi,

How do I read/write Kafka message keys using DDL? I have not been able to see any documentation for the same.

Thanks!

[Manas Kale]

Okay, thanks for the info! 

On Fri, Jul 24, 2020 at 2:11 PM Leonard Xu <[hidden email]> 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

在 2020年7月24日，15:01，Manas Kale <[hidden email]> 写道：

Hi,

How do I read/write Kafka message keys using DDL? I have not been able to see any documentation for the same.

Thanks!