Kafka different partitions are selected python confluent_kafka library v/s apache kafka Java
I found a way to force confluent_kafka Producer to use murmur2 algorithm to determine partition. You can set below parameter with value:
'partitioner': 'murmur2_random'
I am publishing same data (Topic, Key & Value) from python confluent_kafka library based Producer v/s Java apache library based producer but when messages checked on Kafka then they are published to different 
Kafka Partition.
I was expecting by default both these library will use same hash method (murmur2) on Key and will determine same partition when publishing message to Kafka, but looks like that is is not happening.
Is there flag or option that needs to be set on Python library so that it will use same algorithm and generate same (as Java library) Kafka partition OR is there any other python library that should be used to achieve this?