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!

Reply via email to