b-social/kafka-event-processor

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.

Install

Add the following to your project.clj file:

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

Documentation

• API Docs

Usage

Run test with lein test

Publishing

kafka-event-processor gets published to clojars.org/b-social/kafka-event-processor Which can be done following these steps:

1. Create an account on Clojars

2. Get added to the b-social group

   • Current admins are: Elizabeth, Lucas, Natalia, Paul

3. Create a deploy key with b-social scope here

4. Commit the version change like this

5. Run lein test

6. Run lein deploy clojars

   • Use your clojars deploy key, not password

7. Commit the snapshot version change like this

Further reading

• Clojars wiki - deploy tokens
• lein tutorial - snapshot versions
• lein docs - deploy

License

Copyright © 2020 Kroo Ltd

Distributed under the terms of the MIT License.