Liking cljdoc? Tell your friends :D


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 project.clj file:

[b-social/kafka-event-processor "0.1.7"]



Run test with lein test


Copyright © 2020 Kroo Ltd

Distributed under the terms of the MIT License.

Can you improve this documentation? These fine people already did:
Alex Parlett, Paul Hutchin, Matt Weeks & Shamir D
Edit on GitHub

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close