All 7 Streams questions
More in Streams
What is a Redis Stream, and how does it differ from a regular Redis list when used as a messaging system? How do you add a new entry to a Redis Stream, and how do you read entries back from it? How do you acknowledge that a message read from a consumer group has been successfully processed? How do you limit the size of a Redis Stream to prevent it from growing indefinitely and consuming unlimited memory? How would you handle a message that was delivered to a consumer but never acknowledged, perhaps because that consumer crashed while processing it? How would you design a robust event sourcing system using Redis Streams as the primary event log?
Advertisement
Redis › Streams

What is a consumer group in Redis Streams, and how does it enable multiple workers to process the same stream cooperatively?

Intermediate

Answer

A consumer group lets multiple different consumers share the workload of processing a single stream, with Redis ensuring each message is only delivered to one consumer within that specific group, while different consumer groups can independently receive and process every message in the stream separately from each other.
XGROUP CREATE orders processing_group '$'
XREADGROUP GROUP processing_group worker1 COUNT 1 STREAMS orders '>'
Real-world example An order processing system runs several worker instances all belonging to the same consumer group, with Redis automatically distributing each new order event to only one of the available workers, effectively load balancing the processing work.

Common follow-ups: What happens if a worker in a consumer group crashes while processing a message?;Can you have multiple independent consumer groups reading the exact same stream?

Redis as a Message Queue;Distributed Locks with Redis
All 7 Streams questions