Hi, I'm running Flink 1.9.0 and I'm trying to set the key to be published by the Table API's Kafka Connector. I've searched the documentation by could find no reference for such an ability.
Additionally, while browsing the code of the KafkaTableSink, it looks like it creates a KeyedSerializationSchemaWrapper which just sets the key to null? Would love some help. -- Best Regards, Yuval Itzchakov.
