Hey, I don't think we are currently supporting this, but it would be a good idea to have Kafka sink with support for keys. I have worked on something similar to SQL Client before it was created, but the keys in Kafka are crucial to us and this is currently the limitation that keeps us from switching to SQL-Client.
This shouldn't be really that hard as the name of the field to be used as a key could be defined in the environment file, possibly when defining the schema. This would be then used in the *KafkaTableSourceSinkFactory* to create the *KeyedSerializationSchema *instead of wrapper which is used currently. For some applications keys are crucial and this would be the next step to allow creating fully detached jobs from SQL Client. Please, let me know what do You think about this. Best Regards, Dom.
