{"repo":"kensuio-oss/redis-streams-zio","free":true,"listed":false,"github":"https://github.com/kensuio-oss/redis-streams-zio","clone":"git clone https://github.com/kensuio-oss/redis-streams-zio.git","description":"An example application leveraging zio-streams and Redisson library to consume and produce events to Redis streams.","language":"Scala","stars":25,"topics":["zio","redis","zio-streams","streams"],"license":"MIT","category":"databases-storage","readme_excerpt":"redis-streams-zio The Redis Stream consumer and producer implementation with ZIO-Streams. Targets Java 11. Prerequisites Run Redis and Redis Insight docker containers. 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 1. 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.","default_branch":null,"files":null,"tree":[],"storefront":"/r/kensuio-oss","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/kensuio-oss/redis-streams-zio/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}