カフカのパーティション選択アルゴリズム

Question

カフカはmath.abs（key.hashCode）％numPartitionsを使用して送信するパーティションを計算します。

hashCodeがInteger.MIN_VALUEの場合はどうなりますか？

math.abs（Integer.MIN_VALUE）が負の数であるため、kafkaは負のパーティションに送信します。私はこれをどう扱うべきですか？

Answer 1

実際に、これをカフカコードで検索すると、math.abs（）を使用して、ネガをポジティブに変換しません。

それはそれを使用します。

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

だからそれは数が2147483648である場合でも、あなたは心配して問題を解決することができ、それは0

確定数を変換する安価な方法に変換されます。正の値にする。入力が の場合、元の値が返されます。入力番号が負の場合、返された の正の値は元の値のビットであり、0x7fffffffとは絶対的に の値ではありません。