Kafka的分区选择算法

Question

Kafka 使用 math.abs(key.hashCode) % numPartitions 计算要发送的分区。

如果 hashCode 是 Integer.MIN_VALUE 怎么办？

由于 math.abs(Integer.MIN_VALUE) 是负数，kafka 会发送到负分区。这是怎么处理的，我应该关心这个吗？

Answer 1

实际上，当我在 kafka 代码中搜索时，它不会使用 math.abs() 将负数转换为正数。

它使用那个：

public static int toPositive(int number) {
    return number & 0x7fffffff;
}

所以它可以解决你担心的问题，即使数字是2147483648，它也会被转换为0

确定性地将数字转换为正值的廉价方法。当输入为 正数，返回原值。当输入数为负数时，返回 正值是原始值位与 0x7fffffff 不是绝对值 价值。