Kako deluje replikacija v Kafki?

Question

Accepted Answer

Kafka **ponavlja** particije na več brokerjih za **trajnost in dostopnost** — vsaka particija ima vodilno repliko in sledilne replike. Če broker odpove, prevzame sledilna replika. Razumevanje replikacije je ključno za Kafkino toleranco do napak.

## Kako deluje replikacija

```text
Each PARTITION is replicated across multiple brokers (REPLICATION FACTOR copies, e.g. 3):
  → LEADER replica → handles all reads and writes for the partition
  → FOLLOWER replicas → copy (replicate) the leader's data, staying in sync
  → producers/consumers interact with the LEADER; followers are backups
→ if the leader's broker FAILS → a follower is promoted to leader (failover) → no data loss,
  continued availability
```

## Sinhrone replike (ISR)

```text
ISR (In-Sync Replicas) → the set of replicas CAUGHT UP with the leader:
  → only in-sync replicas are eligible to become leader (ensures the new leader has the data)
  → durability config: acks=all + min.insync.replicas → a write is acknowledged only when
    enough ISRs have it → survives failures without data loss
→ ISR is central to balancing durability and availability
```

## Kompromisi med trajnostjo in dostopnostjo

```text
→ REPLICATION FACTOR (e.g. 3) → more copies = more fault tolerance (survive more failures)
→ acks setting (producer):
  acks=0 → no wait (fast, may lose data)  acks=1 → leader only (may lose on leader failure)
  acks=all → all ISRs confirm (safe, no loss, but slower)
→ min.insync.replicas → minimum ISRs required for a write (durability guarantee)
→ trade-off: stronger durability (acks=all, more replicas) vs throughput/availability
```

## Zakaj je to važno

Razumevanje, kako deluje replikacija v Kafki, je dragoceno, ker je **ključno za Kafkino trajnost in dostopnost** (toleranca do napak), zato je važno za razumevanje in zanesljivo upravljanje Kafke.

Replikacija je način, kako Kafka zagotavlja, da podatki niso izgubljeni in ostanejo dostopni kljub napakam brokerjev.

Razumevanje **kako deluje replikacija** — vsaka particija ponovljena na brokerjih (glede na faktor replikacije) z **vodilno repliko**, ki obdeluje branje/pisanje, in **sledilnimi replikami**, ki jo ponavljajo, tako da se, če odpove broker vodilne replike, sledilna replika promovira (prevzem, kar zagotavlja nadaljevanje dostopnosti brez izgube podatkov) — razlaga Kafkin mehanizem tolerance do napak.

Razumevanje **sinhrenih replik (ISR)** — množica replik, ki so usklajene z vodilno repliko, pri čemer le sinhrone replike lahko postanejo vodilne (kar zagotavlja, da ima nova vodilna replika podatke), ter konfiguracija trajnosti (acks=all plus min.insync.replicas), ki zagotavlja, da so pisanja potrjena le, ko dovolj ISR-jev ima podatke (preživijo napake brez izgube) — je osrednje za ravnotežo med trajnostjo in dostopnostjo v Kafki, wichten operativni koncept.

Razumevanje **kompromisov med trajnostjo in dostopnostjo** — faktor replikacije (več kopij = večja toleranca do napak), nastavka producer **acks** (acks=0 hitro, vendar lahko izgubi podatke, acks=1 samo vodilna, acks=all varno, vendar počasneje), in min.insync.replicas — odraža pomembne odločitve pri konfiguraciji, ki uravnoteženost trajnosti glede na prepustnost in dostopnost.

Ti kompromisi so praktične odločitve pri upravljanju Kafke: močnejša trajnost (acks=all, več replik, višji min ISR) proti zmogljivosti.

Razumevanje replikacije je bistveno za zanesljivo upravljanje Kafke in konfiguriranje ustreznih jamstev za trajnost.

Ker je replikacija ključna za Kafkino trajnost in dostopnost (toleranca do napak preko vodilno/sledilne replikacije in prevzema) ter razumevanje — mehanizma, ISR in kompromisov trajnosti/dostopnosti (faktor replikacije, acks, min ISR) — je važno za zanesljivo upravljanje Kafke in konfiguriranje ustreznih jamstev, je razumevanje, kako deluje replikacija v Kafki, dragoceno, praktično relevantno znanje — osrednje za Kafkino toleranco do napak in trajnost, važno za razumevanje, kako Kafka preživi napake, in za konfiguriranje jamstev trajnosti (acks, faktor replikacije, ISR), ter ključno za zanesljivo upravljanje Kafke.