A pipeline that parses raw usage events, de-duplicates redeliveries, aggregates volume per subscriber into event-time windows, raises threshold alerts, and dead-letters anything unusable. The whole topology is tested without a broker.
- Java 21
- Kafka Streams
- Quarkus
- JUnit
Read case study
23 tests