What is FlowWarden?
FlowWarden Stream Core is an annotation-driven library that brings declarative MongoDB Change Streams to Spring Boot. Zero additional dependencies — just Spring Data MongoDB.Quickstart
Add the dependency and create your first handler in minutes.
How it Works
Understand Change Streams, resume tokens, and the FlowWarden lifecycle.
Annotations Reference
Full reference for all FlowWarden annotations.
Guides
Step-by-step guides for filtering, retry, deployment modes, and more.
Key Features
@ChangeStreamdeclarative handlers with typed event callbacks- Automatic checkpoint & resume using MongoDB-backed resume tokens
- Dead Letter Queue for failed events with retention policies
- Exponential backoff retry via
@RetryPolicy - Server-side filtering with
@Filter - Dual execution modes — Imperative (Spring MVC) or Reactive (WebFlux)
- Zero additional dependencies — only requires Spring Data MongoDB
Compatibility
| Requirement | Version |
|---|---|
| Java | 17+ (recommend 21+) |
| Spring Boot | 3.2.x+ |
| Spring Data MongoDB | 4.2.x+ |
| MongoDB | 6.0+ (Replica Set) |