Kafka的分區選擇算法

Question

Kafka使用math.abs（key.hashCode）％numPartitions來計算要發送的分區。

如果hashCode爲Integer.MIN_VALUE，該怎麼辦？

由於math.abs（Integer.MIN_VALUE）是一個負數，卡夫卡會發送到負分區。這是如何處理的，我應該關心這個嗎？

Answer 1

其實，當我在kafka代碼中搜索它時，它不使用math.abs（）將負值轉換爲正值。

它使用：

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

，因此它可以解決這個問題，你擔心即使號碼是2147483648，它會被轉換爲0

一種廉價的方式向確定性轉換號碼到正值。當輸入爲 爲正時，返回原始值。當輸入數字爲負時，返回的 正值是原始值位AND與0x7fffffff的比值，而不是其絕對值 的值。