- Write event-streaming applications in a declarative way.
- Use the powerful MongoDB aggregation pipeline language to transform data that streams over Kafka topics.
- Manage event-driven state with aggregates, where the business logic is a set of command reducers. The aggregate state is kept in MongoDB, which results in efficient Kafka consumer group management.
- Test framework for creating unit tests for your applications.
- Auto-scaling of applications based on the message lag constraints and Kafka topic width.
- Place validators on data-streams using the powerful MongoDB expression language, which lets you validate much more than just the structure of messages.
- Join event-streams based on criteria described with the MongoDB expression language.
- Merge multiple event-streams into one.
- Add your own MongoDB aggregation pipeline stages and MongoDB expression operators through plugins.
- Generation of documentation, directly from the applications.
- Observability of the data-streams.