You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Manas Kale <ma...@gmail.com> on 2020/07/24 07:01:01 UTC

Reading/writing Kafka message keys using DDL pyFlink

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

Thanks!

Re: Reading/writing Kafka message keys using DDL pyFlink

Posted by Manas Kale <ma...@gmail.com>.
Okay, thanks for the info!

On Fri, Jul 24, 2020 at 2:11 PM Leonard Xu <xb...@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 <ma...@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!
>
>
>

Re: Reading/writing Kafka message keys using DDL pyFlink

Posted by Leonard Xu <xb...@gmail.com>.
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 <ma...@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!
>