A libary to process kafka events making a number of choices
- Using stuartsierra components
- Event processing is wrapped in a jdbc transaction
- Configured using environment variables from configurati
- Logs using cambium
Processors are configurable to whether the topic needs to be re-wound, there is idempotency and a callback when event processing is completed.
Allows for multiple processors configured in different ways.
Add the following to your
Run test with
Copyright © 2020 Kroo Ltd
Distributed under the terms of the