Note: this release contains some breaking changes for Consumer's plainStream, partitionedStream, partitionedAssignmentStream and consumeWith, as well as some of the companion objects on parameters used for the AdminClient methods. It should be relatively easy to upgrade though.
To upgrade, calls to Consumer.subscribeAnd(subscription).plainStream(keySerde, valueSerde) should be replaced with Consumer.plainStream(subscription, keySerde, valueSerde), likewise for partitionedStream.
See #517, #620 and #539 for more details.
Changes
- Support for multiple subscriptions on the same Consumer @svroonland (#517)
- Replace key&value tuple with ConsumerRecord in consumeWith @duxet (#620)
- Avoid using a
Taskwhen code is pure. Prefer to useTry@guizmaii (#539) - Avoid extra latency potentially happening between
Pollcalls @guizmaii (#668) - Optimize
Runloop::endRevoked,Runloop::fulfillRequests, andRunloop::bufferRecordsForUnrequestedPartitionscode @guizmaii (#666) - Optimize
Runloop::handleRequestscode @guizmaii (#667) - No need to instantiate more than one
State.initialinstance @guizmaii (#657) - Clean some code @guizmaii (#652)
- Add transactional test @erikvanoosten (#644)
- added missing type annotations @aashish2054 (#636)
- Update README.md @github-actions (#635)
🌱 Dependency Updates
- Upgrade to kafka 3.4.0 @svroonland (#650)
- Update zio, zio-streams, zio-test, ... to 2.0.9 @github-actions (#641)
- Update zio, zio-streams, zio-test, ... to 2.0.8 @github-actions (#634)
- Update scalafmt-core to 3.7.2 @github-actions (#659)
- Bump scala-steward-org/scala-steward-action from 2.49.0 to 2.50.0 @dependabot (#647)
- Bump actions/setup-java from 3.9.0 to 3.10.0 @dependabot (#637)