FS2-Kafka: Functional Kafka Streams for Scala
Getting started
For the latest stable version, see the badge at the top of this page. If your project uses cats-effect 2 you should instead use the latest release from the 1.x series.
Version matrix
| fs2-kafka | scala | cats-effect/fs2 | kafka-clients | status |
|---|---|---|---|---|
| 3.x | 2.12, 2.13, 3.2+ | 3.x | 3.x | Current |
| 2.x | 2.12, 2.13, 3.2+ | 3.x | 2.x | Deprecated |
| 1.x | 2.12, 2.13, 3.2+ | 2.x | 2.x | End-of-life |
For further details, see the microsite.
Integrations
- Trace4Cats, a distributed tracing system, provides a module for integrating with fs2-kafka.
Contributing
Pull requests and feedback are welcome. Pull requests should usually target the series/2.x branch
Adopters
FS2-Kafka is used in production by a number of companies, including:
Code of conduct
All participants are expected to follow the Scala Code of Conduct.