Hi all, I've just come across a FlinkKafkaProducer misconfiguration issue especially when a FlinkKafkaProducer is created without specifying a kafka partitioner then a FlinkFixedPartitioner instance is used, and all messages end up in a single kafka partition (in case I have a single task manager instance). Just curious if it was done on purpose? Don't you consider a round robin strategy more suitable for this case? For now if I need a round-robin strategy I have to explicitly pass null value for it
Thanks in advance. Kind Regards, Mike Pryakhin
smime.p7s
Description: S/MIME cryptographic signature
