Skip to content

README.md

Latest commit

 

History

History
17 lines (14 loc) · 701 Bytes

README.md

File metadata and controls

17 lines (14 loc) · 701 Bytes

MsgSync: Scalable Notification System

MsgSync is a demonstration of a Pulsar-based notification service built with Scala and ZIO. It enables sending and processing email/push notifications via multi-topic producers and consumers, showcasing effectful, composable messaging in a layered architecture.

Tools and Versions

  • Scala: 3.7.3
  • ZIO: 2.1.22 (core, streams, JSON, config)
  • Apache Pulsar: Via Pulsar4s 2.12.0.1 & Java Client 4.1.2
  • Avro4s: 5.0.14 (serialization)
  • Circe: 0.14.15 (JSON)
  • SBT: Build tool
  • Others: Kyo 1.0-RC1, Kafka Clients 4.1.0

Quick Start

  1. `sbt compile`
  2. Update `msg-pulsar.conf` for Pulsar.
  3. `sbt run` (runs NotifierDemoApp)