Alpakka Kafka 2.1.x

Note

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

The Alpakka Kafka 2.1 series features

  • Kafka 2.7.0 client
  • Akka 2.6.x (dropped Akka 2.5)
  • Scala 2.12 and 2.13 (dropped Scala 2.11)
  • Testkit: use ScalaTest 3.1.x
  • Testkit: default to use Confluent Platform 6.1.1
  • Testkit: no longer support Embedded Kafka (Kafka 2.6.0 can’t be safely embedded in Scala applications)

2.1.1

Released: 2021-07-23

Alpakka Kafka core

  • Upgrade Akka 2.6.15 #1395 by @ygree
  • Fix Lightbend Telemetry context propagation in CommitCollectorStage #1395 by @ygree

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

Author Commits Lines added Lines removed
ygree ygree 6 68 23

2.1.0

Released: 2021-05-14

Noteworthy

  • Akka typed first documentation user experience #1370 by @seglo

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

Author Commits Lines added Lines removed
scala-steward scala-steward 5 11 11
seglo seglo 1 265 7

2.1.0-RC1

Note

The Apache Kafka clients have a provided dependency on Jackson 2.10.5, but Akka depends on 2.11.4. Alpakka Kafka references 2.11.4.

Released: 2021-04-19

Noteworthy

  • Upgrade Akka 2.6.14 and Kafka 2.7.0 #1355 by @seglo
  • Add configurable protection against server-bug induced resets #1299 by @jyates
  • Don’t depend on scalatest in testcontainer singleton #1330 by @seglo

Alpakka Kafka core

  • Upgrade Akka 2.6.14 and Kafka 2.7.0 #1355 by @seglo
  • Add configurable protection against server-bug induced resets #1299 by @jyates

Tests

  • Upgrade Akka 2.6.14 and Kafka 2.7.0 #1355 by @seglo
  • Increase consumer group summary timeout in build #1329 by @seglo
  • Add configurable protection against server-bug induced resets #1299 by @jyates
  • Migrate build to GitHub actions #1307 by @seglo

Alpakka Kafka Testkit

  • Upgrade Akka 2.6.14 and Kafka 2.7.0 #1355 by @seglo
  • Don’t depend on scalatest in testcontainer singleton #1330 by @seglo
  • Add ProducerResultFactory.multiResult helper for MultiMessage #1319 by @ashendon

Documentation

  • Upgrade Akka 2.6.14 and Kafka 2.7.0 #1355 by @seglo
  • Migrate to sonatype snapshot/release repositories #1353 by @seglo
  • Add configurable protection against server-bug induced resets #1299 by @jyates
  • Release notes v2.0.7 (master) #1317 by @seglo
  • Migrate build to GitHub actions #1307 by @seglo

Contributors

Since 2.0.7 Alpakka Kafka has received contributions by:

Author Commits Lines added Lines removed
scala-steward scala-steward 39 41 41
ennru ennru 35 515 296
seglo seglo 25 2516 2593
octonato octonato 2 4 4
jyates jyates 1 925 71
jhooda jhooda 1 381 20
Matzz Matzz 1 94 65
altomch altomch 1 51 52
ashendon ashendon 1 8 0
johanandren johanandren 1 1 1
kciesielski kciesielski 1 1 1

2.1.0-M1

Released: 2020-10-22

Noteworthy

  • Kafka 2.6.0 client #1098
  • Akka 2.6.10 (dropped Akka 2.5) #1113
  • Scala 2.12 and 2.13 (dropped Scala 2.11) #1102
  • The testkit does no longer support Embedded Kafka #1114
  • Scala 2.12.11 and 2.13.2 #1212 by @ennru

Alpakka Kafka core

Alpakka Kafka Testkit

  • testkit: Admin instead of AdminClient #1183 by @ennru
  • Testkit: enable Mima #1230 by @ennru
  • Start & stop Kafka process within running container #1235 by @seglo
  • Drop embedded-kafka testkit support #1229 by @seglo
  • Rollback Confluent Platform version; add Jackson Databind #1226 by @ennru
  • Default to Confluent Platform version to 6.0.0 #1224 by @ennru

Documentation

  • Docs: show Lightbend Telemetry OpenTracing support #1237 by @ennru

Tests

Other updates

The milestone contains everything closed in 2.1.0-M1.

Contributors

Since 2.0.5 Alpakka Kafka has received contributions by:

Author Commits Lines added Lines removed
ennru ennru 27 338 253
seglo seglo 11 1577 2228
scala-steward scala-steward 6 6 6
herzrasen herzrasen 1 34 0
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.