Functional Kafka Streams for Scala
Changes introduced in #1126 cause a significant performance drop in Producer (you can find more details with some nice graphs in #1321).
Users are encouraged to use v3.5.1 and avoid v3.5.0 for this reason.
Many thanks to @atnoya for noticing and seeking the root cause 🎉 (and mention to @abestel for confirming he was experiencing the same issues).
tlBaseVersion
to match latest tag by @aartigao in https://github.com/fd4s/fs2-kafka/pull/1323
Full Changelog: https://github.com/fd4s/fs2-kafka/compare/v3.5.0...v3.5.1
A leak in the fetch loop caused by a misuse of the CE Fiber API has been found and fixed (more info in #1318). Of course, all users are encouraged to upgrade ⬆️
All credits to @abestel who took the time to investigate the root cause a propose a fix for it! 🙇🏽 🥇 Awesome contribution! 🎉
Depending on the usage, the leak advances slowly or faster. As an example, here's the graph of one of our services for the last 12h in Staging (with the SNAPSHOT that includes #1318) and Prod (with v3.4.0) (both envs share exactly the same load) 👇🏽
CallbackStack.Node
leak by @abestel in https://github.com/fd4s/fs2-kafka/pull/1318
tlBaseVersion
to match latest tag by @aartigao in https://github.com/fd4s/fs2-kafka/pull/1313
RebalanceInProgressException
in CommitRecovery.Default
by @aartigao in https://github.com/fd4s/fs2-kafka/pull/1312
Blocking
to use Sync#interruptible
, not blocking
by @bastewart in https://github.com/fd4s/fs2-kafka/pull/1126
Full Changelog: https://github.com/fd4s/fs2-kafka/compare/v3.4.0...v3.5.0
This release contains mostly version bumps for the library dependencies, but some of them are important enough to create a minor version 👇🏽
aartigao
to developers list by @aartigao in https://github.com/fd4s/fs2-kafka/pull/1298
sbt-typelevel
umbrella by @aartigao in https://github.com/fd4s/fs2-kafka/pull/1297
NotSubscribedException
message by @aartigao in https://github.com/fd4s/fs2-kafka/pull/1303
Full Changelog: https://github.com/fd4s/fs2-kafka/compare/v3.3.1...v3.4.0
This release fixes v3.3.0 by bringing back the binary incompatible changes.
Users are encouraged to use v3.3.1 and avoid v3.3.0 for this reason.
Full Changelog: https://github.com/fd4s/fs2-kafka/compare/v3.3.0...v3.3.1
This is the fifth stable fs2-kafka release to be based on the 3.x series of the Apache Kafka client library. It is available for Scala 2.12, 2.13, and 3.3; all users are encouraged to upgrade.
Thanks for the effort of the new contributors @cwholmes and @L7R7 🎉 We hope to see more nice contributions in the future! 💪🏽 🙌🏽
This release introduced binary incompatibilities in #1268. Users are encouraged to use v.3.3.1 instead 🙏🏽
Stream.iterable
instead of Stream.emits
by @aartigao in https://github.com/fd4s/fs2-kafka/pull/1266
-Xsource:3
) by @aartigao in https://github.com/fd4s/fs2-kafka/pull/1267
KafkaConsumer#assignmentStream
tests by @aartigao in https://github.com/fd4s/fs2-kafka/pull/1274
Full Changelog: https://github.com/fd4s/fs2-kafka/compare/v3.2.0...v3.3.0
This is the fourth stable fs2-kafka release to be based on the 3.x series of the Apache Kafka client library. It is available for Scala 2.12, 2.13, and 3.3; all users are encouraged to upgrade.
Full Changelog: https://github.com/fd4s/fs2-kafka/compare/v3.1.0...v3.2.0
This is the third stable fs2-kafka release to be based on the 3.x series of the Apache Kafka client library. It is available for Scala 2.12, 2.13, and 3.3; all users are encouraged to upgrade.
Development of the 2.x series is now discontinued. All new pull requests should target the 3.x branch.
This release bumps all third party dependencies to latest effective version (targeting JDK 8 as the base), fixes some transitive vulnerabilities and consolidates the build for Cats Effect 3.5.x and fs2 3.9.x.
Thanks everyone involved in the release and congrats to first-time contributors! 🥳 We hope to see more of your nice PRs in the near future! 💪🏽
series/2.x
as EOL by @aartigao in https://github.com/fd4s/fs2-kafka/pull/1248
Full Changelog: https://github.com/fd4s/fs2-kafka/compare/v3.0.1...v3.1.0
This release makes some internal changes in preparation for changes to cancelation semantics forthcoming in cats-effect 3.5.0; it also updates some dependencies.
Full Changelog: https://github.com/fd4s/fs2-kafka/compare/v3.0.0...v3.0.1
This release makes some internal changes in preparation for changes to cancelation semantics forthcoming in cats-effect 3.5.0; it also updates some dependencies.
Full Changelog: https://github.com/fd4s/fs2-kafka/compare/v2.6.0...v2.6.1
This is likely to be the final release of fs2-kafka v1.x, unless a serious security vulnerability emerges; please upgrade to v3.0.0.
Full Changelog: https://github.com/fd4s/fs2-kafka/compare/v1.10.0...v1.11.0