Stream — append-only лог записей с ID; потребители читают по offset/ID, есть consumer groups — ближе к «лёгкому Kafka внутри Redis», но с другими лимитами.
Разбор
XADD пишет, XREAD/XREADGROUP читает.- Consumer group координирует нескольких воркеров.
- Pending entries (
XPENDING) — незакрытые сообщения.
- Данные живут в Redis — планируйте память и тримминг (
MAXLEN/XTRIM).
Итог
Streams — персистентный (в рамках Redis) поток событий с группами потребителей.