Što su Redis Streams?

Question

Accepted Answer

**Redis Streams** su struktura podataka tipa append-only log — poput trajnog reda čekanja za poruke ili tipa dnevnika događaja — koji podržavaju **grupe konzumenata**, trajnost poruka, potvrde i ponovnu reprodukciju. To je Redisov odgovor na pouzdanu razmjenu poruka, robusniji od Pub/Sub-a (koji je fire-and-forget).

## Append-only dnevnik poruka

```bash
# add entries to a stream (each gets an auto ID: timestamp-sequence)
XADD events * type "signup" user "ann"     # * = auto-generate ID; returns e.g. 1700000000-0
XADD events * type "login" user "bob"

XLEN events                                 # number of entries
XRANGE events - +                           # read all entries (- to +)
XREAD COUNT 10 STREAMS events 0             # read entries (from ID 0)
```

Streamovi su **append-only dnevnik**: stavke se dodaju pomoću `XADD` (svaka s jedinstvenim, vremenski-poredanim ID-om) i ostaju u streamu — za razliku od Pub/Sub-a, poruke se ne gube; pohranjuju se i mogu se ponovno pročitati.

## Grupe konzumenata — pouzdana, skalabilna obrada

```bash
# create a consumer group to process the stream
XGROUP CREATE events workers 0

# consumers read messages (each message goes to ONE consumer in the group)
XREADGROUP GROUP workers consumer1 COUNT 1 STREAMS events >

# acknowledge a processed message (so it's not redelivered)
XACK events workers 1700000000-0
# unacknowledged messages can be reclaimed (XPENDING/XCLAIM) → no message lost on crash
```

**Grupe konzumenata** distribuiraju poruke među više konzumenata (skaliranje obrade), pri čemu svaka poruka ide jednom konzumentu, **potvrde** (`XACK`) potvrđuju obradu, a **na čekanju/preuzimanje** (`XPENDING`/`XCLAIM`) osiguravaju da se poruke ne gube ako konzument padne — pouzdana, at-least-once dostava.

## Streamovi vs Pub/Sub

```text
PUB/SUB  → fire-and-forget; offline subscribers MISS messages; no persistence/replay
STREAMS  → PERSISTENT log; messages stored; consumer groups; acknowledgments; replay
  → Streams = when you need RELIABLE delivery, message history, and scalable consumers
  → Pub/Sub = simple real-time broadcast where missing messages is OK
Streams are similar to a lightweight Kafka (log + consumer groups).
```

## Zašto je to važno

Razumijevanje Redis Streamova vredno je za **pouzdanu razmjenu poruka i obradu događaja** unutar Redis-a, pa je to korisno znanje — posebno jer Streamovi rješavaju ključna ograničenja Pub/Sub-a.

Dok je Pub/Sub jednostavan, ali fire-and-forget (offline suradnici zauvijek propuštaju poruke, nema trajnosti), **Streamovi pružaju pouzdanu razmjenu poruka**: **append-only trajni dnevnik** gdje se poruke pohranjuju (ne gube) i mogu se ponovno pročitati/reproducirati, plus **grupe konzumenata** koje distribuiraju poruke među više konzumenata za skalabilnu obradu, **potvrde** (`XACK`) za potvrdu obrade, i **preuzimanje poruka na čekanju** (`XPENDING`/`XCLAIM`) kako se poruke ne bi izgubile kada konzument padne — pružajući at-least-once, pouzdanu, skalabilnu obradu poruka.

Razumijevanje **Streamova vs Pub/Sub-a** (Streamovi za pouzdanu dostavu, историју i skalabilne konzumente; Pub/Sub za jednostavnu real-time emitiranje gdje je gubitak prihvatljiv) važno je za odabir prave Redis razmjene poruka.

Prepoznavanje da su Streamovi **slični laganomu Kafka-ju** (log-based s grupama konzumenata) pomaže u utvrđivanju njihove uloge — pružajući event-streaming/message-queue mogućnosti unutar Redis-a bez odvojeног brokera za umjerene potrebe, dok specijalizirani brokeri (Kafka, RabbitMQ) ostaju odgovarajući za veću skalu ili zahtjevnije razmjene poruka.

Budući da su pouzdana razmjena poruka i obrada događaja česte potrebe, a budući da Streamovi pružaju robusno, trajno, grupe-konzumenata-bazirano rješenje (prevladavajući fire-and-forget ograničenje Pub/Sub-a) unutar Redis-a, razumijevanje Redis Streamova — append-only dnevnika, grupa konzumenata s potvrdama i preuzimanjem, i kako se uspoređuju s Pub/Sub-om i Kafka-jem — vredno je, praktično relevantno znanje za razvoj pouzdane razmjene poruka i event-driven značajki s Redis-om, pravi odabor kada trebate jamstva dostave i historiju poruka koje Pub/Sub ne može pružiti.