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!