A simple Redis Streams fan-out POC written in Go.
This project shows how one event stream can be consumed by multiple platforms, where each platform processes the same events independently and can scale its own workers.
Events are added to a single Redis Stream. Each platform reads the stream using its own consumer group, so every platform receives all events. Within a platform, multiple consumers process events in parallel. Redis manages message delivery, acknowledgments, and recovery.
External calls are simulated by time.Sleep(2 * time.Second)
docker compose up --build
Starts Redis and all consumers using Docker.