Alpakka Kafka 1.0-M1

First milestone release for Alpakka Kafka 1.0

On this Road to Alpakka 1.0 we may introduce non-compatible API changes - but did not in Alpakka Kafka 1.0-M1 vs. 0.22. From version 1.0 Alpakka will stay binary-compatible between minor releases.

Having that said, Alpakka Kafka will start to make use of the @ApiMayChange annotation to keep the door open for API changes, so that new feature API can evolve more rapidly than other parts of Alpakka Kafka.

Highlights in this release

  • Upgraded the Kafka client to version 2.0.0 #544 by @fr3akX (with huge improvements to come in #614 by an enormous effort of @zaharidichev)

  • New Committer.sink for standardised committing #622 by @rtimush

  • Commit with metadata #563 and #579 by @johnclara

  • Factored out akka.kafka.testkit for internal and external use: see Testing

  • Support for merging commit batches #584 by @rtimush

  • Reduced risk of message loss for partitioned sources #589

  • Expose Kafka errors to stream #617

  • Java APIs for all settings classes #616

  • Much more comprehensive tests

Improved documentation

Everything done in this release is in the milestone.

General information

This release is compiled and tested against Akka 2.5 and Scala 2.11 and 2.12.

This release was made possible by new and earlier contributors:

commits  added  removed
     84   7657     4762 Enno
     29   1543      693 Martynas Mickevičius
      2    345       17 Roman Timushev
      2    279       32 John Clara
      1     24       18 Philippus Baalman
      1     18        3 fr3akX
      1      3        2 Sherif Ebady
      1      2        1 Piotr Gabara
Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.