This release brings important fixes in the rebalancing mechanism, as well as other minor improvements.
A couple of methods are now deprecated:
Serde#inmapM
, renamed toinmapZIO
Deserializer#contramapM
, renamed tocontramapZIO
Serializer#mapM
, renamed tomapZIO
Consumer#fromJavaConsumer(javaConsumer)
, replaced byfromJavaConsumerWithPermit
If you are using scala-steward, the renamed methods are automatically changed.
🚀 Changes
- Add example dashboard to docs by @erikvanoosten in #1357
- Fix slow rebalanceSafeCommits behavior by @svroonland in #1358
- Remove attemptBlocking from AdminClient by @svroonland in #1359
- Fix concurrent modification exception in Consumer release by @svroonland in #1365
- Fix stream interrupt when no data, Add tests for
PartitionStreamControl
by @svroonland in #1371 - More logging around rebalancing when rebalanceSafeCommits is true by @svroonland in #1360
- Require a semaphore in Consumer.fromJavaConsumer by @svroonland in #1368
- Rename Serde methods for consistency with ZIO 2 by @svroonland in #1378
- Fix deprecation notice version on Consumer.fromJavaConsumer by @svroonland in #1379
- Decouple stream halt detection timeout from max poll interval by @svroonland in #1376
🌱 Dependency Updates
- Update kafka-clients and embedded-kafka to 3.8.1 by @zio-scala-steward in #1352
- Update zio-kafka, zio-kafka-testkit to 2.8.3 by @zio-scala-steward in #1353
- Update zio, zio-streams, zio-test, ... to 2.1.12 by @zio-scala-steward in #1364
🔧 Maintenance
- Update README.md by @zio-assistant in #1355
- Update sbt to 1.10.5 by @zio-scala-steward in #1362
- Automate pruning of benchmark history by @erikvanoosten in #1370
- Fix automatic pruning of benchmark history by @erikvanoosten in #1372
- Fix automatic pruning of benchmark history (attempt 2) by @erikvanoosten in #1373
- Bump scala-steward-org/scala-steward-action from 2.70.0 to 2.71.0 by @dependabot in #1377
- Use
max.poll.records
i.s.o. config name by @erikvanoosten in #1381 - Formatting by @svroonland in #1383
- Disable mima check for new minor releases by @erikvanoosten in #1384
Full Changelog: v2.8.3...v2.9.0