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. >
