¿Qué son Redis Streams?

Question

Accepted Answer

**Redis Streams** son una estructura de datos de registro de solo-append — como una cola de mensajes duradera o registro de eventos — que admite **grupos de consumidores**, persistencia de mensajes, confirmaciones y reproducción. Son la respuesta de Redis a la mensajería confiable, más robustos que Pub/Sub (que es de dispara-y-olvida).

## Registro de solo-append de mensajes

```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 es un **registro de solo-append**: las entradas se añaden con `XADD` (cada una con un ID único ordenado por tiempo) y persisten en el stream — a diferencia de Pub/Sub, los mensajes no se pierden; se almacenan y pueden ser re-leídos.

## Grupos de consumidores — procesamiento confiable y escalable

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

Los **grupos de consumidores** distribuyen mensajes entre múltiples consumidores (escalando el procesamiento), con cada mensaje yendo a un consumidor, **confirmaciones** (`XACK`) confirmando el procesamiento, y **pendiente/reclamación** (`XPENDING`/`XCLAIM`) asegurando que los mensajes no se pierdan si un consumidor falla — entrega confiable, al-menos-una-vez.

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

## Por qué es importante

Entender Redis Streams es valioso para **mensajería confiable y procesamiento de eventos** dentro de Redis, por lo que es conocimiento útil — particularmente porque Streams abordan las limitaciones clave de Pub/Sub.

Mientras que Pub/Sub es simple pero de dispara-y-olvida (los suscriptores fuera de línea pierden permanentemente los mensajes, sin persistencia), **Streams proporcionan mensajería confiable**: un **registro persistente de solo-append** donde los mensajes se almacenan (no se pierden) y pueden ser re-leídos/reproducidos, más **grupos de consumidores** que distribuyen mensajes entre múltiples consumidores para procesamiento escalable, **confirmaciones** (`XACK`) para confirmar el procesamiento, y **reclamación de mensajes pendientes** (`XPENDING`/`XCLAIM`) para que los mensajes no se pierdan cuando un consumidor falla — entregando procesamiento confiable, escalable y al-menos-una-vez.

Entender **Streams vs Pub/Sub** (Streams para entrega confiable, historial y consumidores escalables; Pub/Sub para transmisión en tiempo real simple donde la pérdida es aceptable) es importante para elegir la primitiva de mensajería de Redis correcta.

Reconocer que Streams son **similares a un Kafka ligero** (basado en registro con grupos de consumidores) ayuda a enmarcar su rol — proporcionando capacidades de flujo de eventos/cola de mensajes dentro de Redis sin un broker separado para necesidades moderadas, mientras que los brokers dedicados (Kafka, RabbitMQ) siguen siendo apropiados para mensajería de mayor escala o más exigente.

Como la mensajería confiable y el procesamiento de eventos son necesidades comunes, y como Redis Streams proporciona una solución robusta, persistente y basada en grupos de consumidores (superando la limitación de dispara-y-olvida de Pub/Sub) dentro de Redis, entender Redis Streams — el registro de solo-append, grupos de consumidores con confirmaciones y reclamación, y cómo se comparan con Pub/Sub y Kafka — es conocimiento valioso y prácticamente relevante para construir características de mensajería confiable y basadas en eventos con Redis, la opción correcta cuando necesitas garantías de entrega e historial de mensajes que Pub/Sub no puede proporcionar.