The app is a web socket server for broadcasting kafka messages for some preconfigured topics. It's built for the educational purpose of a blog post series about programming with ZIO library. I encourage you to read the posts first.
The code uses ZIO version 2.
- Part one, covers basic of ZIO effects, streams and layers - link
- Part two, covers basics of concurrency and web sockets handling - link
- Part three, covers testing - link
I assume sbt is installed on your OS.
- start Kafka & Zookeeper using provided docker compose file,
docker compose up - Run the dummy producer which will send random messages to test Kafka
topic,
sbt "project producer" "run" - Run the server with
sbt "project server" "run"