Apa itu Redis Streams?

Question

Accepted Answer

**Redis Streams** adalah struktur data append-only log — seperti message queue yang tahan lama atau event log — mendukung **consumer groups**, persistensi pesan, acknowledgments, dan replay. Mereka adalah jawaban Redis untuk reliable messaging, lebih robust dibanding Pub/Sub (yang bersifat fire-and-forget).

## Append-only log pesan

```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 adalah **append-only log**: entri ditambahkan dengan `XADD` (masing-masing dengan ID yang unik dan terurut waktu) dan persisten dalam stream — tidak seperti Pub/Sub, pesan tidak hilang; mereka disimpan dan dapat dibaca ulang.

## Consumer groups — reliable, scalable processing

```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** mendistribusikan pesan di antara beberapa consumers (scaling pemrosesan), dengan setiap pesan pergi ke satu consumer, **acknowledgments** (`XACK`) mengkonfirmasi pemrosesan, dan **pending/reclaim** (`XPENDING`/`XCLAIM`) memastikan pesan tidak hilang jika seorang consumer crash — reliable, 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).
```

## Mengapa ini penting

Memahami Redis Streams bernilai untuk **reliable messaging dan event processing** dalam Redis, jadi ini pengetahuan yang berguna — khususnya karena Streams mengatasi keterbatasan utama Pub/Sub.

Sementara Pub/Sub sederhana namun fire-and-forget (subscribers offline secara permanen melewatkan pesan, tidak ada persistensi), **Streams menyediakan reliable messaging**: **append-only persistent log** di mana pesan disimpan (tidak hilang) dan dapat dibaca ulang/diputar ulang, plus **consumer groups** yang mendistribusikan pesan di antara beberapa consumers untuk scalable processing, **acknowledgments** (`XACK`) mengkonfirmasi pemrosesan, dan **pending-message reclaim** (`XPENDING`/`XCLAIM`) sehingga pesan tidak hilang saat consumer crash — memberikan at-least-once, reliable, scalable message processing.

Memahami **Streams vs Pub/Sub** (Streams untuk reliable delivery, history, dan scalable consumers; Pub/Sub untuk simple real-time broadcast di mana loss dapat diterima) penting untuk memilih Redis messaging primitive yang tepat.

Mengenali bahwa Streams **mirip dengan lightweight Kafka** (log-based dengan consumer groups) membantu membingkai peran mereka — menyediakan event-streaming/message-queue capabilities dalam Redis tanpa broker terpisah untuk kebutuhan sedang, sementara dedicated brokers (Kafka, RabbitMQ) tetap sesuai untuk messaging yang lebih besar atau lebih demanding.

Karena reliable messaging dan event processing adalah kebutuhan umum, dan karena Redis Streams menyediakan solusi yang robust, persistent, consumer-group-based (mengatasi keterbatasan fire-and-forget Pub/Sub) dalam Redis, memahami Redis Streams — append-only log, consumer groups dengan acknowledgments dan reclaim, dan bagaimana mereka dibandingkan dengan Pub/Sub dan Kafka — adalah pengetahuan yang bernilai, praktis-relevan untuk membangun reliable messaging dan event-driven features dengan Redis, pilihan yang tepat saat Anda memerlukan delivery guarantees dan message history yang tidak bisa disediakan Pub/Sub.

Append-only log pesan

Consumer groups — reliable, scalable processing

Streams vs Pub/Sub

Mengapa ini penting

question.related