X'inhu Redis Streams?

Question

Accepted Answer

**Redis Streams** huma struttura tad-data append-only log — bħal queue ta' messaġġi durabbli jew event log — li jappoġġaw **consumer groups**, persistenza ta' messaġġi, acknowledgments, u replay. Huma r-risposta ta' Redis għal messaging affidabbli, aktar robustt minn Pub/Sub (li hija fire-and-forget).

## Append-only log ta' messaġġi

```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)
```

Streams huma **append-only log**: l-entries jiżdiedu ma' `XADD` (kull waħda b'ID unika, ordnata b'ħin) u jifdal fil-stream — għall-kuntrarju ta' Pub/Sub, il-messaġġi mhumiex mitlufa; huma maħżuna u jistgħu jitlestu mill-ġdid.

## Consumer groups — processing affidabbli u skalabbli

```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
```

**Consumer groups** jiddistrbuixxu messaġġi fuq ħafna consumers (jiżdiedu l-processing), kull messaġġ jmur għal consumer waħda, **acknowledgments** (`XACK`) jikkonfermu l-processing, u **pending/reclaim** (`XPENDING`/`XCLAIM`) jiżguraw li l-messaġġi ma jintilfu jekk consumer jikraxxa — affidabbli, at-least-once delivery.

## Streams 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).
```

## Għaliex dan għandu importanza

L-għarfien ta' Redis Streams jkun ta' valur għal **reliable messaging u event processing** ġewwa Redis, għalhekk huwa għarfien utli — partikolarment għax Streams jiddirizzjaw il-limitazzjonijiet ewlenin ta' Pub/Sub.

Benħa Pub/Sub hija sempliċi pero fire-and-forget (subscribers offline jimmissu permanentement il-messaġġi, m'hemm l-ebda persistenza), **Streams jipprovdu reliable messaging**: **append-only persistent log** fejn il-messaġġi jiġu maħżuna (mhumiex mitlufa) u jistgħu jitlestu mill-ġdid/jirrimplajaw, flimkien ma' **consumer groups** li jiddistrbuixxu messaġġi fuq ħafna consumers għall-processing skalabbli, **acknowledgments** (`XACK`) biex jikkonfermu l-processing, u **pending-message reclaim** (`XPENDING`/`XCLAIM`) sabiex il-messaġġi ma jintilfu meta consumer jikraxxa — li jipprovdu at-least-once, affidabbli, skalabbli message processing.

L-għarfien ta' **Streams vs Pub/Sub** (Streams għall-affidabbilità tad-delivery, l-istorja, u consumers skalabbli; Pub/Sub għal broadcast real-time sempliċi fejn it-telf huwa aċċettabbli) huwa importanti biex tagħżel il-primitiva t-tajba ta' Redis messaging.

L-għarfien li Streams huma **simili għal Kafka leġġer** (log-based b'consumer groups) jgħin biex infram ir-rwol tagħhom — jipprovdu event-streaming/message-queue capabilities ġewwa Redis mingħajr broker separata għal bżonniet moderati, filwaqt li brokers dedikati (Kafka, RabbitMQ) jibqgħu xierqa għal messaging akbar jew aktar eżiġenti.

Għax reliable messaging u event processing huma bżonniet komuni, u bħal Streams jipprovdu soluzzjoni robusta, persistenti, basata fuq consumer groups (jgħorru l-limitazzjoni fire-and-forget ta' Pub/Sub) ġewwa Redis, l-għarfien ta' Redis Streams — il-append-only log, consumer groups b'acknowledgments u reclaim, u kif jqabblu ma' Pub/Sub u Kafka — huwa għarfien ta' valur, relevant praktikament, għall-bini ta' reliable messaging u features event-driven b'Redis, il-għażla t-tajba meta għandek bżonn ta' guarantee tad-delivery u message history li Pub/Sub ma tistax tipprovdi.