[GitHub] [flink] cricket007 commented on issue #6181: [FLINK-9610] [flink-connector-kafka-base] Add Kafka Partitioner that uses the hash of the provided key.

[GitHub]

Kafka uses a Murmur2 Hash, not `Arrays.hashCode`

https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/producer/internals/DefaultPartitioner.java#L69

[ Full content available at: https://github.com/apache/flink/pull/6181 ]
This message was relayed via gitbox.apache.org for devnull@infra.apache.org