Skip to content

Latest commit

 

History

History
37 lines (23 loc) · 1.15 KB

README.md

File metadata and controls

37 lines (23 loc) · 1.15 KB
Raw

redis-streams-zio

example workflow

The Redis Stream consumer and producer implementation with ZIO-Streams. Targets Java 11.

Prerequisites

Run Redis and Redis Insight docker containers.

docker-compose -f docker/docker-compose.yaml up

Checking the events passing around

You can take a look what is happening inside Redis with Redis Insight tool.

  1. Head to http://localhost:8002
  2. Add a new instance:
    • host: host.docker.internal
    • port: 6377
    • pass: supersecret

Running sample apps

The project is configured to work over notifications stream.

Producer

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.

Consumer

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.