The Redis Stream consumer and producer implementation with ZIO-Streams. Targets Java 11.
Run Redis and Redis Insight docker containers.
docker-compose -f docker/docker-compose.yaml up
You can take a look what is happening inside Redis with Redis Insight tool.
- Head to http://localhost:8002
- Add a new instance:
- host:
host.docker.internal
- port:
6377
- pass:
supersecret
- host:
The project is configured to work over notifications
stream.
You can run a sample event producer of notifications with sbt 'runMain io.kensu.redis_streams_zio.Producer'
.
This will produce a random String event to the notifications
stream, under add
key every ~5 seconds.
You can run a sample event producer of notifications with sbt 'runMain io.kensu.redis_streams_zio.Consumer'
.
This will keep consuming the notifications
stream from add
key, ignoring events under different keys with logged info about that.