Functional streams for Kafka with FS2 and the official Apache Kafka client.
Project is under active development. Feedback and contributions welcome.
To get started with sbt, simply add the following line to your
libraryDependencies += "com.github.fd4s" %% "fs2-kafka" % "2.3.0"
Published for Scala 2.12, 2.13 and 3.1. For changes, refer to the release notes.