redis-streams-rails

What problem does it solve?

Rails applications already using Redis lack persistent, replayable event streaming with consumer groups when using plain Redis pub/sub, but adding Kafka introduces unnecessary operational overhead for medium-throughput, single-region workloads.

Core Features & Use Cases

• Redis Streams Implementation: Uses XADD, XREADGROUP, and consumer groups for reliable event processing with persistence and replay capabilities.
• Production Hardening: Includes MAXLEN stream caps, pending entry list (PEL) handling with XAUTOCLAIM for abandoned entries, and PEL depth monitoring for alerting.
• Migration Guidance: Provides clear criteria for when to switch to Kafka for high-throughput, cross-region, or long-retention scenarios. Use case: A Rails e-commerce app using Redis for caching can implement order event streaming for inventory updates without deploying a separate Kafka cluster.

Quick Start

Use the redis-streams-rails skill to set up a Redis Streams event pipeline with consumer groups and automatic abandoned entry reaping for your Rails application.