Kastle - Kafka Client

CircleCI Maven Central

A purely functional, effectful, resource-safe, kafka library for Scala


The packages are published on Maven Central.

The latest version is 1.1.x. See the badge at the top of the README for the exact version number.

libraryDependencies += "com.tenable.library" %% "Kastle" % "1.1.x"

Getting started


The kastle project welcomes contributions from anybody wishing to participate. All code or documentation that is provided must be licensed with the same license that kastle is licensed with (Apache 2.0, see LICENSE.txt).

People are expected to follow the Scala Code of Conduct when discussing kastle on GitHub, Gitter, or other venues.

Feel free to open an issue if you notice a bug, have an idea for a feature, or have a question about the code. Pull requests are also gladly accepted. For more information, check out the contributor guide.


Mdoc docs.


Mdoc docs.


Unit tests:

sbt test

Integration tests Integration tests will run against an in-memory kafka.

sbt it:test


All code in this repository is licensed under the Apache License, Version 2.0. See LICENCE.md.

Generated Mdoc documentation:

Raw (Always updated)

Generated Mdoc (Might be outdated)