Jackdaw ·

Jackdaw is a Clojure library for the Apache Kafka distributed streaming platform. With Jackdaw, you can create and list topics using the AdminClient API, produce and consume records using the Producer and Consumer APIs, and create stream processing applications using the Streams API. Jackdaw also contains functions to serialize and deserialize records as JSON, EDN, and Avro, as well as functions for writing unit and integration tests.

Supported versions

Jackdaw currently only works with Clojure >= 1.10. This is because we are using the datafy protocol which was only introduced in 1.10.

Documentation

You can find all the documentation on cljdoc.

Examples

Pipe
Word Count
Simple Ledger

Contributing

We welcome any thoughts or patches. You can reach us in #jackdaw (or open an issue).

License