Kako funkcionira redoslijed poruka u Kafki?

Question

Accepted Answer

Kafka jamči **redoslijed unutar particije**, ali **ne i preko particija** — ključni koncept. Da biste dobili redoslijed za povezane događaje, rutirte ih u istu particiju (preko istog ključa). Razumijevanje redoslijeda je važno za ispravnost.

## Redoslijed po particiji

```text
Kafka guarantees:
  ✓ ORDER WITHIN a partition → events in a partition are strictly ordered (by offset);
    consumers read them in order
  ✗ NO order ACROSS partitions → events in different partitions have no relative order
    guarantee (they're processed in parallel by different consumers)
→ this is a FUNDAMENTAL Kafka property (and a common source of misunderstanding)
```

## Dobivanje redoslijeda za povezane događaje

```text
To keep RELATED events ordered → send them to the SAME partition:
  → use the SAME KEY for related events (key → hash → same partition):
    e.g. all events for orderId=5 use key=5 → same partition → ordered for that order
  → so per-entity ordering: key by the entity (userId, orderId, accountId)
→ choose the key so events that must be ordered share a partition
```

## Kompromisi i razmatranja

```text
⚠️ Ordering vs PARALLELISM → ordering within a key/partition limits parallelism for that key
  (all of one key's events are processed by one consumer, in order)
⚠️ A few things break ordering: producer retries (without idempotence + max.in.flight=1),
  adding partitions (changes key→partition mapping)
→ if you DON'T need ordering → no key (spread freely for max parallelism)
→ if you NEED ordering → key appropriately; accept the parallelism scope
```

## Zašto je to važno

Razumijevanje redoslijeda poruka u Kafki je vrijedno jer je **redoslijed temeljni, često pogrešno shvaćeni Kafka koncept** važan za ispravnost, pa je to bitno znanje.

Kafkina garancija redoslijeda je specifična i ključna za razumijevanje.

Razumijevanje **redoslijeda po particiji** — da Kafka jamči redoslijed **unutar particije** (događaji strogo poredani po offsetu, čitani redoslijedno) ali **ne i preko particija** (događaji u različitim particijama nemaju relativni redoslijed, obrađuju se paralelno) — je temeljno Kafkino svojstvo i **čest izvor nesporazuma** (ljudi često pogrešno pretpostavljaju globalni redoslijed), pa je ispravno razumijevanje ključno za ispravnost.

Razumijevanje kako **dobiti redoslijed za povezane događaje** — slanjem ih u istu particiju korištenjem **istog ključa** (tako da povezani događaji poput svih događaja za određenu narudžbu ili korisnika, označeni tom jedinicom, idu u istu particiju i ostaju poredani) — je ključna praktična tehnika za postizanje redoslijeda koji je potreban aplikacijama (redoslijed po entitetu kroz ključanje).

Razumijevanje **kompromisa i razmatranja** — da redoslijed unutar ključa/particije **ograničava paralelizam** za taj ključ (svi događaji jednog ključa obrađeni su od strane jednog konzumenta redoslijedno), da nekoliko stvari prekida redoslijed (retry-anja producenta bez idempotencije i max.in.flight=1, dodavanje particija koje mijenjaju mapiranje ključa), i da trebate koristiti nema ključa kada redoslijed nije potreban (za maksimalni paralelizam) ali prikladne ključe kada jest (prihvaćajući scope paralelizma) — odražava nijansiranu analizu potrebnu za dizajniranje ispravnog redoslijeda uz balansiranje paralelizma.

Ovo znanje o redoslijedu je važno jer pogrešan pristup (pretpostavljanje globalnog redoslijeda ili ključanje događaja koji trebaju redoslijed) uzrokuje prave greške ispravnosti.

Budući da je redoslijed temeljni, često pogrešno shvaćeni Kafka koncept (samo po particiji, zahtijevajući ključeve za redoslijed povezanih događaja) važan za ispravnost, i budući da je razumijevanje garancije, kako postići redoslijed preko ključeva, i kompromisa (redoslijed vs paralelizam) bitno, razumijevanje redoslijeda poruka u Kafki je vrijedno, bitno Kafkino znanje — temeljni, često pogrešno shvaćeni koncept ključan za ispravnost, gdje je razumijevanje redoslijeda po particiji i rutiranja temeljenog na ključu za povezane događaje (i kompromisa paralelizma) potrebno za dizajniranje Kafkinih sustava koji redoslijedno obrađuju događaje, ključan koncept koji svaki Kafkin korisnik mora točno razumjeti.