Alpakka Kafka 2.0.x

The Alpakka Kafka 2.0 series features

• upgrade to 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

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

  • Stage ID traceability #995 by @seglo

This release contains contributions by:

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

2.0.0-M2

Released: 2019-12-03

Notable changes since 1.1.0

• Kafka 2.4.0-RC1

  • Kafka 2.4.0-RC1 #971 by @seglo

• 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	26	4167	1434
seglo	6	1521	882
charlibot	1	1901	664
jewertow	1	668	12
def1ne	1	6	0
shobull	1	1	1

2.0.0-M1

The release process failed.