Kastle - Kafka Client

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

Usage

The packages are published on Maven Central.

See the badge at the top of the README for the latest version number.

libraryDependencies += "com.tenable" %% "kastle" % "<version>"

Getting started

• Consumer examples
• Producer examples

Contributing

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.

Producer

Mdoc docs.

Consumer

Mdoc docs.

Development

Unit tests:

sbt test

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

sbt it:test

License

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)