Çfarë janë Redis Streams?

Question

Accepted Answer

**Redis Streams** janë një strukturë të dhënash append-only log — si një radhë mesazhesh e qëndrueshme ose event log — që mbështesin **consumer groups**, përqëndrimin e mesazheve, konfirmimet, dhe ripërsëritjen. Ato janë përgjigja e Redis-it ndaj mesazheve të besueshme, më të fuqishme sesa Pub/Sub (i cili është fire-and-forget).

## Append-only log mesazhesh

```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 janë një **append-only log**: hyrjet shtohen me `XADD` (secila me një ID unike, të renditur sipas kohe) dhe vazhdojnë në stream — ndryshe nga Pub/Sub, mesazhet nuk humbasin; ato ruhen dhe mund të rilexohen.

## Consumer groups — përpunim i besueshëm, i shkallëzueshëm

```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** shpërndajnë mesazhet midis konsumatorëve të shumtë (duke shkallëzuar përpunimin), ku secili mesazh shkon tek një konsumator, **konfirmimet** (`XACK`) konfirmojnë përpunimin, dhe **pending/reclaim** (`XPENDING`/`XCLAIM`) sigurojnë që mesazhet nuk humbasin nëse një konsumator bie — përvojë e besueshme, 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).
```

## Pse ka rëndësi

Kuptimi i Redis Streams është i vlefshëm për **mesazherim të besueshëm dhe përpunimin e ngjarjeve** brenda Redis-it, kështu që është njohuri e dobishme — veçanërisht sepse Streams adresojnë kufizimet kryesore të Pub/Sub.

Ndërsa Pub/Sub është i thjeshtë por fire-and-forget (abonohet offline përgjithmonë humbasin mesazhe, pa përqëndrimin), **Streams ofrojnë mesazherim të besueshëm**: një **append-only persistent log** ku mesazhet ruhen (nuk humbasin) dhe mund të rilexohen/ripërsëriten, plus **consumer groups** që shpërndajnë mesazhet midis konsumatorëve të shumtë për përpunim të shkallëzueshëm, **konfirmimet** (`XACK`) për të konfirmuar përpunimin, dhe **reclaim e mesazheve pending** (`XPENDING`/`XCLAIM`) kështu që mesazhet nuk humbasin kur një konsumator bie — duke dhënë at-least-once, mesazherim të besueshëm, të shkallëzueshëm.

Kuptimi i **Streams vs Pub/Sub** (Streams për delivery të besueshme, historiku, dhe konsumatorë të shkallëzueshëm; Pub/Sub për broadcast real-time të thjeshtë ku humbja është e pranueshme) është i rëndësishëm për zgjedhjen e primitivit të duhur të Redis për mesazherim.

Kuptimi që Streams janë **të ngjashme me një Kafka të lehtë** (log-based me consumer groups) ndihmon të kuadrohej roli i tyre — duke ofruar aftësi të streaming-ut të ngjarjeve/radhë mesazhesh brenda Redis pa një broker të ndarë për nevojat e moderuara, ndërsa brokerat e dedikuar (Kafka, RabbitMQ) mbeten të përshtatshëm për mesazherim me shkallë më të madhe ose më të kërkueshëm.

Meqenëse mesazherim i besueshëm dhe përpunimi i ngjarjeve janë nevojat e zakonshme, dhe meqenëse Redis Streams ofrojnë një zgjidhje të fortë, të përqëndrueshme, bazuar në consumer groups (duke kapërcyer kufizimin fire-and-forget të Pub/Sub) brenda Redis, kuptimi i Redis Streams — append-only log, consumer groups me konfirmime dhe reclaim, dhe si ata krahasohen me Pub/Sub dhe Kafka — është njohuri e vlefshme, praktikisht-relevante për ndërtimin e mesazhimit të besueshëm dhe karakteristikat event-driven me Redis, zgjedha e duhur kur keni nevojë për garansi delivery dhe historik mesazhesh që Pub/Sub nuk mund të ofrojë.