We are happy to announce the general availability of Alpakka Kafka 2.0.0!
Alpakka Kafka 2.0.0 uses the Apache Kafka client 2.4.0 which contains improvements to the flow-control management that are very important to Alpakka Kafka. You can learn more about these improvements in the Lightbend blog post How Alpakka Uses Flow Control Optimizations In Apache Kafka 2.4.
Producer.committableSink behave as a combination of
Committer.sink, but has a special-purpose implementation which shows better performance in our benchmarks.
This release adds built-in support for service discovery with Akka Discovery.
To reduce emitting duplicated records when partitions are revoked from Alpakka Kafka consumers, this release introduces dropping of messages when partitions are revoked.
For detailed changes, please see the release notes in the Alpakka Kafka documentation.
– The Alpakka Team