Redis

Streams Commands

Build event sourcing and message streaming with Redis Streams. Learn XADD, XREAD, and consumer groups for durable, scalable message processing.

10 commands

Pro Tips

Use consumer groups for reliable message processing - messages are tracked and can be re-processed.

XREAD with BLOCK waits for new messages - no polling required, efficient for real-time.

Use XACK to acknowledge processed messages in consumer groups, enabling retry on failure.

Common Mistakes

Streams grow unbounded by default. Use MAXLEN or XTRIM to cap stream size.

Commands

Add to stream

$ XADD stream * field value

Add entry to stream with auto-generated ID

Claim abandoned messages

$ XAUTOCLAIM stream group consumer min-idle-time start

Automatically claim pending messages from other consumers

Create consumer group

$ XGROUP CREATE stream group $ MKSTREAM

Create consumer group for stream

Reset consumer group

$ XGROUP SETID stream group $ ENTRIESREAD 0

Reset consumer group position to start or specific entry

Detailed stream info

$ XINFO STREAM mystream FULL

Get comprehensive stream information including entries and groups

Get stream length

$ XLEN stream

Get number of entries in stream

View pending messages

$ XPENDING stream group - + 10

Get detailed information about pending messages in consumer group

Get stream range

$ XRANGE stream - +

Get all entries in stream

Read from stream

$ XREAD STREAMS stream 0

Read entries from stream

Read as consumer

$ XREADGROUP GROUP group consumer STREAMS stream >

Read stream entries as consumer group member