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 |
6 | 68 | 23 |
2.1.0
Released: 2021-05-14
Noteworthy
The detailed list of changes is found in the 2.1.0 Github release listing.
| Author | Commits | Lines added | Lines removed |
|---|---|---|---|
 scala-steward |
5 | 11 | 11 |
 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 |
39 | 41 | 41 |
 ennru |
35 | 515 | 296 |
| seglo |
25 | 2516 | 2593 |
 octonato |
2 | 4 | 4 |
 jyates |
1 | 925 | 71 |
 jhooda |
1 | 381 | 20 |
 Matzz |
1 | 94 | 65 |
 altomch |
1 | 51 | 52 |
 ashendon |
1 | 8 | 0 |
 johanandren |
1 | 1 | 1 |
 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
- DiscoverySupport: remove deprecation #1231 by @ennru
- Drop Akka 2.5 dependency #1209 by @seglo
- Kafka 2.6.0 client upgrade and drop Scala 2.11 support #1102 by @seglo
- Commit collector: avoid pushing twice #1205 by @ennru
- Commit the offset when multi message is empty #1201 by @herzrasen
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
Tests
Other updates
- akka-stream-alpakka-csv 2.0.2 (was 2.0.1) #1215 by @scala-steward
- Use the latest JDK 8 and 11 versions in CI #1213 by @ennru
- protobuf-java 3.12.4 (was 3.12.2) #1170 by @scala-steward
- scala-collection-compat 2.2.0 (was 2.1.6) #1219 by @scala-steward
- junit-jupiter-api 5.7.0 (was 5.5.2) #1217 by @scala-steward
- mockito-core 3.5.13 (was 3.4.6) #1218 by @scala-steward
- sbt-mima-plugin 0.8.0 (was 0.7.0) #1216 by @scala-steward
- Lock scalafmt version #1236 by @ennru
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 |
27 | 338 | 253 |
 seglo |
11 | 1577 | 2228 |
 scala-steward |
6 | 6 | 6 |
 herzrasen |
1 | 34 | 0 |