go-redis-streams

Messing around with Redis Streams in Go

How to run example

• docker-compose up
• cd example/producer && go run main.go

TODO

• To() - Should be able to stream into another data source
• Via() - Should group and process messages on the shard