Hello,as far as i can this is not possible. I'm including Timo, maybe he can explain why this isn't supported.
On 26.03.2018 21:56, Pavel Ciorba wrote:
Hi everyone! Can I specify a *message key* using the Kafka sink in the Table/SQL API ?The goal is to sink each row as JSON along side with a message key into Kafka.I was achieving it using the Stream API by specifying a *KeyedSerializationSchema* using the *serializeKey() *method.Thanks in advance!
