Hi Till, KafkaSerializationSchema is only pluggable for the DataStream API, not for the Table API. KafkaTableSink hard codes a KeyedSerializationSchema that uses a null key, and this behavior can't be overridden.
I have to say I was quite surprised by this behavior, as publishing events to Kafka using a key to keep order inside a given partition is usually a very common requirement. On Thu, Aug 20, 2020 at 10:26 AM Till Rohrmann <trohrm...@apache.org> wrote: > Hi Yuval, > > it looks as if the KafkaTableSink only supports writing out rows without a > key. Pulling in Timo for verification. > > If you want to use a Kafka producer which writes the records out with a > key, then please take a look at KafkaSerializationSchema. It supports this > functionality. > > Cheers, > Till > > On Wed, Aug 19, 2020 at 6:36 PM Yuval Itzchakov <yuva...@gmail.com> wrote: > >> Hi, >> >> I'm running Flink 1.9.0 and I'm trying to set the key to be published by >> the Table API's Kafka Connector. I've searched the documentation by >> could find no reference for such an ability. >> >> Additionally, while browsing the code of the KafkaTableSink, it looks >> like it creates a KeyedSerializationSchemaWrapper which just sets the key >> to null? >> >> Would love some help. >> >> -- >> Best Regards, >> Yuval Itzchakov. >> > -- Best Regards, Yuval Itzchakov.
