Append-only log with consumer groups. Persistent alternative to Pub/Sub.
Basics¶
XADD events * type click user_id 123
XRANGE events - + COUNT 10
XLEN events
Consumer Groups¶
XGROUP CREATE events mygroup $ MKSTREAM
XREADGROUP GROUP mygroup consumer1 COUNT 5 BLOCK 2000 STREAMS events >
XACK events mygroup 1234567890-0
Advantages vs Pub/Sub¶
- Persistence
- Consumer groups
- Acknowledgment
- Replay
Streams = Kafka-lite¶
Sufficient for most use cases instead of Kafka.
redisstreamsevent sourcing