Hi Vishwas,
You should pay attention to the other args.
The constructor provided by you has a `KeyedSerializationSchema` arg, while
the comments of the constructor which made you confused only has a
`SerializationSchema` arg. That's their difference.
Best,
Vino
Vishwas Siravara 于2019年11月6日周三
Hi all,
I am using flink 1.7.0 and using this constructor
FlinkKafkaProducer(String topicId, KeyedSerializationSchema
serializationSchema, Properties producerConfig)
>From the doc it says this constructor uses fixed partitioner. I want to
partition based on key , so I tried to use this
public
