KafkaPartition不匹配MurmurHash232-bit算法

如果在使用 Kafka 的 Murmur2Partitioner 时遇到 Partition 不匹配的问题，可以尝试使用 Java 自带的 MurmurHash3 32-bit 算法来替代。以下是相应的代码示例：

import org.apache.kafka.common.utils.Utils;

public class MyPartitioner implements Partitioner {
    public int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster) {
        List<PartitionInfo> partitions = cluster.partitionsForTopic(topic);
        int numPartitions = partitions.size();
        if (keyBytes == null) {
            return Utils.toPositive(ThreadLocalRandom.current().nextInt() % numPartitions);
        } else {
            return Utils.toPositive(Utils.murmur3(keyBytes)) % numPartitions;
        }
    }
    public void close() {
        // nothing to close
    }
    public void configure(Map<String, ?> configs) {
        // nothing to configure
    }
}

代码中使用了 Utils.murmur3() 方法来生成 Partition，它使用的是 Java 自带的 MurmurHash3 32-bit 算法。使用该方法可以解决 Kafka Partition 不匹配 MurmurHash2 32-bit 算法的问题。