That's what I concluded as well after checking the docs and source code. I'm thinking to add another job using the Stream API (where it is possible), that will ingest the data resulted from by Table/SQL API job, and that will add the message key into Kafka.
On 27 March 2018 at 12:55, Chesnay Schepler <ches...@apache.org> wrote: > 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! > > >
