Mire való a partíciókulcs? Hogyan határozza meg a Kafka a partíciót a kulcs alapján?

A Kafka-ban a partíciókulcs szükséges ahhoz, hogy meghatározzuk, melyik partícióba kerül egy adott üzenet. Ez fontos azonos kulccsal rendelkező üzenetek sorrendjének biztosításához és a terhelés kiegyensúlyozásához a partíciók között.

A Kafka a kulcsot használja egy hash érték kiszámítására, általában egy hash függvény (pl. murmur2) segítségével. Ezután ezt az értéket a partíciók számával osztva modulo értéket vesz, hogy meghatározza a partíció indexét:

int partition = (key == null) ?
    véletlenszerűPartíció() :
    Math.abs(hash(key)) % partíciókSzáma;

Így minden ugyanazzal a kulccsal rendelkező üzenet garantáltan ugyanabba a partícióba kerül, ami fontos a sorrendiség és a feldolgozás konzisztenciája szempontjából.