Functional streams for Kafka with FS2 and the official Apache Kafka client.
Project is under active development. Feedback and contributions welcome.

Getting Started

To get started with sbt, simply add the following line to your build.sbt file.

libraryDependencies += "com.github.fd4s" %% "fs2-kafka" % "3.7.0"

Published for Scala 2.12, 2.13 and 3.3. For changes, refer to the release notes.