flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Table/SQL Kafka Sink Question
Date Tue, 27 Mar 2018 09:55:07 GMT

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!

View raw message