Alpakka Kafka 2.0.x

Note

In case you are browsing a specific version’s documentation: check out the latest release notes

The Alpakka Kafka 2.0 series features

  • upgrade to the Apache Kafka client 2.4.0
  • Producer.committableSink behaves as a combination of Producer.flexiFlow and Committer.sink, but has a special-purpose implementation
  • built-in Akka Discovery support
  • More versatile use of Testcontainers in Alpakka Kafka Testkit #939.
  • Removal of some API which was deprecated since 1.0.0 or earlier.
  • Internal filter to avoid emitting records of revoked partitions #946 and #992

2.0.2

Released: 2020-02-20

This release fixes

Alpakka Kafka core

Alpakka Kafka Testkit

The milestone contains everything closed in 2.0.2.

Since 2.0.1 Alpakka Kafka has received contributions by:

Author Commits Lines added Lines removed
gabrielreid gabrielreid 5 328 14
seglo seglo 5 151 84
ennru ennru 2 18 21
jewertow jewertow 1 44 1
ignasi35 ignasi35 1 16 3
Sebruck Sebruck 1 1 1

2.0.1

Released: 2020-01-23

This release fixes

  • CommittableProducer: Record outstanding commits on pass-through #1022 by @gabrielreid
  • Producer: avoid race between failure and upstream finish #1025

The detailed list of changes is found in the 2.0.1 Github release listing.

Since 2.0.0 Alpakka Kafka has received contributions by:

Author Commits Lines added Lines removed
ennru ennru 2 60 44
gabrielreid gabrielreid 1 78 0

2.0.0

Released: 2020-01-15

This release doesn’t contain any relevant changes over 2.0.0-RC1.

The detailed list of changes is found in the 2.0.0 Github release listing.

Since 1.1.0 Alpakka Kafka has received contributions by:

Author Commits Lines added Lines removed
ennru ennru 36 4358 1566
seglo seglo 11 2692 1122
charlibot charlibot 1 1901 664
jewertow jewertow 1 668 12
def1ne def1ne 1 6 0
shobull shobull 1 1 1

2.0.0-RC1

Released: 2019-12-17

Notable changes since 2.0.0-M2

  • Kafka 2.4.0 Final

    • Update to Kafka 2.4.0 final release #971 by @ennru
  • Bugs

    • Rebalance: filter messages of revoked partitions in partitioned sources #992 by @seglo
  • Alpakka Kafka API

This release contains contributions by:

Author Commits Lines added Lines removed
ennru ennru 5 75 85
seglo seglo 2 494 186

2.0.0-M2

Released: 2019-12-03

Notable changes since 1.1.0

  • Kafka 2.4.0-RC1

  • Producer.committableSink behaves as a combination of Producer.flexiFlow and Committer.sink, but has a special-purpose implementation

    • Committing producer sink: producer and committer in a sink stage #963 by @ennru
    • Create committableSink as combination of Producer.flexiFlow an… #932 by @ennru
    • Committer: change type bound to allow offset batches #931 by @ennru
  • Akka Discovery support #836 by @ennru

  • Add wrapper for Metadata requests #497 #900 by @jewertow

  • Offset batches allow aggregation from multiple consumers #953 by @ennru

  • Performance

    • As part of Apache Kafka: KafkaConsumer should not throw away already fetched data for paused partitions apache/kafka#6988 by @seglo
    • Producer: change default parallelism #944 by @ennru
    • Rebalance: filter messages of revoked partitions #946 by @ennru
  • Testkit

    • Use testcontainers for multi-broker integration tests and benchmarks #939 by @seglo
    • Make EmbeddedKafka a provided dependency #954 by @ennru
  • Alpakka Kafka API

    • Committable: deprecate commitJavadsl and commitScaladsl #959 by @ennru
    • ConsumerSetting: Add group instance id setter #861 by @def1ne
  • Bugs

    • Commit refreshing: fix bug from aggregating offsets #975 by @ennru
    • Consumer drops records after rebalance #978 band-aided with #997

The detailed list of changes is found in the 2.0.0-M2 Github release listing.

This release is compiled and tested against Akka 2.5.23, 2.6.0 and Scala 2.11, 2.12, 2.13 on Adopt OpenJDK 8 and 11.

This release contains contributions by:

Author Commits Lines added Lines removed
ennru ennru 26 4167 1434
seglo seglo 6 1521 882
charlibot charlibot 1 1901 664
jewertow jewertow 1 668 12
def1ne def1ne 1 6 0
shobull shobull 1 1 1

2.0.0-M1

The release process failed.

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.