zio/zio-kafka v2.1.1

on GitHub

(Same as 2.1.0 with some artifact publishing fixes. Release notes for 2.1.0 are repeated below)

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 Task when code is pure. Prefer to use Try @guizmaii (#539)
• Avoid extra latency potentially happening between Poll calls @guizmaii (#668)
• Optimize Runloop::endRevoked, Runloop::fulfillRequests, and Runloop::bufferRecordsForUnrequestedPartitions code @guizmaii (#666)
• Optimize Runloop::handleRequests code @guizmaii (#667)
• No need to instantiate more than one State.initial instance @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)