feat: support for Pekko Streams in the scala client (influxdata#661)

* feat: support for Pekko Streams in the scala client BREAKING CHANGE: This client version discontinues support for Akka Streams and introduces support for Pekko Streams instead. * chore(deps): bump org.apache.commons:commons-lang3 from 3.13.0 to 3.14.0 (influxdata#669) * chore(deps): bump org.apache.commons:commons-lang3 from 3.13.0 to 3.14.0 Bumps org.apache.commons:commons-lang3 from 3.13.0 to 3.14.0. --- updated-dependencies: - dependency-name: org.apache.commons:commons-lang3 dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> * docs: Update CHANGELOG.md --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Jakub Bednář <jakub.bednar@gmail.com> * chore(deps): bump io.micrometer:micrometer-registry-influx from 1.11.3 to 1.12.1 (influxdata#670) * chore(deps): bump io.micrometer:micrometer-registry-influx Bumps [io.micrometer:micrometer-registry-influx](https://github.com/micrometer-metrics/micrometer) from 1.11.3 to 1.12.1. - [Release notes](https://github.com/micrometer-metrics/micrometer/releases) - [Commits](micrometer-metrics/micrometer@v1.11.3...v1.12.1) --- updated-dependencies: - dependency-name: io.micrometer:micrometer-registry-influx dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> * docs: Update CHANGELOG.md [skip CI] --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Jakub Bednář <jakub.bednar@gmail.com> * chore(deps): bump io.reactivex.rxjava3:rxjava from 3.1.6 to 3.1.8 (influxdata#667) * chore(deps): bump org.apache.maven.plugins:maven-javadoc-plugin from 3.6.0 to 3.6.3 (influxdata#671) * chore(deps): bump org.apache.maven.plugins:maven-javadoc-plugin Bumps [org.apache.maven.plugins:maven-javadoc-plugin](https://github.com/apache/maven-javadoc-plugin) from 3.6.0 to 3.6.3. - [Release notes](https://github.com/apache/maven-javadoc-plugin/releases) - [Commits](apache/maven-javadoc-plugin@maven-javadoc-plugin-3.6.0...maven-javadoc-plugin-3.6.3) --- updated-dependencies: - dependency-name: org.apache.maven.plugins:maven-javadoc-plugin dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <support@github.com> * docs: Update CHANGELOG.md --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Jakub Bednář <jakub.bednar@gmail.com> * chore(deps): bump junit-jupiter.version from 5.9.1 to 5.10.1 (influxdata#668) * chore(deps): bump junit-jupiter.version from 5.9.1 to 5.10.1 Bumps `junit-jupiter.version` from 5.9.1 to 5.10.1. Updates `org.junit.vintage:junit-vintage-engine` from 5.9.1 to 5.10.1 - [Release notes](https://github.com/junit-team/junit5/releases) - [Commits](junit-team/junit-framework@r5.9.1...r5.10.1) Updates `org.junit.jupiter:junit-jupiter-engine` from 5.9.1 to 5.10.1 - [Release notes](https://github.com/junit-team/junit5/releases) - [Commits](junit-team/junit-framework@r5.9.1...r5.10.1) Updates `org.junit.jupiter:junit-jupiter-api` from 5.9.1 to 5.10.1 - [Release notes](https://github.com/junit-team/junit5/releases) - [Commits](junit-team/junit-framework@r5.9.1...r5.10.1) --- updated-dependencies: - dependency-name: org.junit.vintage:junit-vintage-engine dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: org.junit.jupiter:junit-jupiter-engine dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: org.junit.jupiter:junit-jupiter-api dependency-type: direct:development update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> * docs: Update CHANGELOG.md --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Jakub Bednář <jakub.bednar@gmail.com> * chore(deps): bump com.squareup.okio:okio from 3.6.0 to 3.7.0 (influxdata#666) * chore(deps): bump com.squareup.okio:okio from 3.6.0 to 3.7.0 Bumps [com.squareup.okio:okio](https://github.com/square/okio) from 3.6.0 to 3.7.0. - [Changelog](https://github.com/square/okio/blob/master/CHANGELOG.md) - [Commits](square/okio@parent-3.6.0...parent-3.7.0) --- updated-dependencies: - dependency-name: com.squareup.okio:okio dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> * docs: Update CHANGELOG.md [skip CI] --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Jakub Bednář <jakub.bednar@gmail.com> * chore(deps): bump kotlin.version from 1.9.20 to 1.9.22 (influxdata#664) * chore(deps): bump kotlin.version from 1.9.20 to 1.9.22 Bumps `kotlin.version` from 1.9.20 to 1.9.22. Updates `org.jetbrains.kotlin:kotlin-stdlib` from 1.9.20 to 1.9.22 - [Release notes](https://github.com/JetBrains/kotlin/releases) - [Changelog](https://github.com/JetBrains/kotlin/blob/master/ChangeLog.md) - [Commits](JetBrains/kotlin@v1.9.20...v1.9.22) Updates `org.jetbrains.kotlin:kotlin-maven-plugin` from 1.9.20 to 1.9.22 --- updated-dependencies: - dependency-name: org.jetbrains.kotlin:kotlin-stdlib dependency-type: direct:production update-type: version-update:semver-patch - dependency-name: org.jetbrains.kotlin:kotlin-maven-plugin dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <support@github.com> * docs: Update CHANGELOG.md --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Jakub Bednář <jakub.bednar@gmail.com> * chore(deps): bump org.apache.commons:commons-lang3 from 3.13.0 to 3.14.0 (influxdata#669) * chore(deps): bump org.apache.commons:commons-lang3 from 3.13.0 to 3.14.0 Bumps org.apache.commons:commons-lang3 from 3.13.0 to 3.14.0. --- updated-dependencies: - dependency-name: org.apache.commons:commons-lang3 dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> * docs: Update CHANGELOG.md --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Jakub Bednář <jakub.bednar@gmail.com> * chore(deps): bump junit-jupiter.version from 5.9.1 to 5.10.1 (influxdata#668) * chore(deps): bump junit-jupiter.version from 5.9.1 to 5.10.1 Bumps `junit-jupiter.version` from 5.9.1 to 5.10.1. Updates `org.junit.vintage:junit-vintage-engine` from 5.9.1 to 5.10.1 - [Release notes](https://github.com/junit-team/junit5/releases) - [Commits](junit-team/junit-framework@r5.9.1...r5.10.1) Updates `org.junit.jupiter:junit-jupiter-engine` from 5.9.1 to 5.10.1 - [Release notes](https://github.com/junit-team/junit5/releases) - [Commits](junit-team/junit-framework@r5.9.1...r5.10.1) Updates `org.junit.jupiter:junit-jupiter-api` from 5.9.1 to 5.10.1 - [Release notes](https://github.com/junit-team/junit5/releases) - [Commits](junit-team/junit-framework@r5.9.1...r5.10.1) --- updated-dependencies: - dependency-name: org.junit.vintage:junit-vintage-engine dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: org.junit.jupiter:junit-jupiter-engine dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: org.junit.jupiter:junit-jupiter-api dependency-type: direct:development update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> * docs: Update CHANGELOG.md --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Jakub Bednář <jakub.bednar@gmail.com> --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Jakub Bednář <jakub.bednar@gmail.com>

Author: 3 people

CHANGELOG.md

@@ -1,4 +1,37 @@
-## 6.13.0 [unreleased]
+## 7.0.0 [unreleased]
+
+:warning: This client version discontinues support for Akka Streams and introduces support for Pekko Streams instead. Apache Pekko is a fork of [Akka](https://github.com/akka/akka) 2.6.x, created after the Akka project adopted the Business Source License, which is not compatible with open-source usage.
+
+### Features
+1. [#661](https://github.com/influxdata/influxdb-client-java/pull/661): Replaced Akka Streams with Pekko Streams in the Scala client.
+
+
+### Dependencies
+
+Update dependencies:
+
+#### Build:
+ - [#664](https://github.com/influxdata/influxdb-client-java/pull/664): `kotlin` to `1.9.22`
+ - [#666](https://github.com/influxdata/influxdb-client-java/pull/666): `okio` to `3.7.0`
+ - [#667](https://github.com/influxdata/influxdb-client-java/pull/667): `rxjava` to `3.1.8`
+ - [#669](https://github.com/influxdata/influxdb-client-java/pull/669): `commons-lang3` to `3.14.0`
+ - [#670](https://github.com/influxdata/influxdb-client-java/pull/670): `micrometer-registry-influx` to `1.12.1`
+
+#### Maven:
+ - [#671](https://github.com/influxdata/influxdb-client-java/pull/671): `maven-javadoc-plugin` to `3.6.3`
+
+#### Test:
+ - [#668](https://github.com/influxdata/influxdb-client-java/pull/668): `junit-jupiter` to `5.10.1`
+
+### Dependencies
+
+Update dependencies:
+
+#### Build:
+ - [#669](https://github.com/influxdata/influxdb-client-java/pull/669): `commons-lang3` to `3.14.0`
+
+#### Test:
+ - [#668](https://github.com/influxdata/influxdb-client-java/pull/668): `junit-jupiter` to `5.10.1`
 
 ### Dependencies
 

README.md

@@ -53,14 +53,14 @@ This section contains links to the client library documentation.
 
 The Java, Reactive, OSGi, Kotlin and Scala clients are implemented for the InfluxDB 2.x:
 
-| Client | Description | Documentation | Compatibility |
-| --- | --- | --- | --- |
-| **[java](./client)** | The reference Java client that allows query, write and InfluxDB 2.x management. | [javadoc](https://influxdata.github.io/influxdb-client-java/influxdb-client-java/apidocs/index.html), [readme](./client#influxdb-client-java/)| 2.x |
-| **[reactive](./client-reactive)**  | The reference RxJava client for the InfluxDB 2.x that allows query and write in a reactive way.| [javadoc](https://influxdata.github.io/influxdb-client-java/influxdb-client-reactive/apidocs/index.html), [readme](./client-reactive#influxdb-client-reactive/) |2.x |
-| **[kotlin](./client-kotlin)** | The reference Kotlin client that allows query and write for the InfluxDB 2.x by Kotlin [Channel](https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.channels/-channel/index.html) and [Flow](https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/-flow/index.html) coroutines. | [KDoc](https://influxdata.github.io/influxdb-client-java/influxdb-client-kotlin/dokka/influxdb-client-kotlin/com.influxdb.client.kotlin/index.html), [readme](./client-kotlin#influxdb-client-kotlin/) | 2.x|
-| **[scala](./client-scala)** | The reference Scala client that allows query and write for the InfluxDB 2.x by [Akka Streams](https://doc.akka.io/docs/akka/2.6/stream/). | [Scaladoc](https://influxdata.github.io/influxdb-client-java/client-scala/cross/influxdb-client-scala_2.13/scaladocs/com/influxdb/client/scala/index.html), [readme](./client-scala#influxdb-client-scala/) | 2.x |
-| **[osgi](./client-osgi)** | The reference OSGi (R6) client embedding Java and reactive clients and providing standard features (declarative services, configuration, event processing) for the InfluxDB 2.x. | [javadoc](https://influxdata.github.io/influxdb-client-java/influxdb-client-osgi/apidocs/index.html), [readme](./client-osgi) | 2.x |
-| **[karaf](./karaf)** | The Apache Karaf feature definition for the InfluxDB 2.x. | [readme](./karaf) | 2.x |
+| Client  | Description  | Documentation  | Compatibility |
+|-----------------------------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------------|
+| **[java](./client)**  | The reference Java client that allows query, write and InfluxDB 2.x management.  | [javadoc](https://influxdata.github.io/influxdb-client-java/influxdb-client-java/apidocs/index.html), [readme](./client#influxdb-client-java/) | 2.x  |
+| **[reactive](./client-reactive)** | The reference RxJava client for the InfluxDB 2.x that allows query and write in a reactive way. | [javadoc](https://influxdata.github.io/influxdb-client-java/influxdb-client-reactive/apidocs/index.html), [readme](./client-reactive#influxdb-client-reactive/)  | 2.x  |
+| **[kotlin](./client-kotlin)**  | The reference Kotlin client that allows query and write for the InfluxDB 2.x by Kotlin [Channel](https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.channels/-channel/index.html) and [Flow](https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow/-flow/index.html) coroutines. | [KDoc](https://influxdata.github.io/influxdb-client-java/influxdb-client-kotlin/dokka/influxdb-client-kotlin/com.influxdb.client.kotlin/index.html), [readme](./client-kotlin#influxdb-client-kotlin/)  | 2.x |
+| **[scala](./client-scala)**  | The reference Scala client that allows query and write for the InfluxDB 2.x by [Pekko Streams](https://pekko.apache.org/docs/pekko/current/stream/index.html).  | [Scaladoc](https://influxdata.github.io/influxdb-client-java/client-scala/cross/influxdb-client-scala_2.13/scaladocs/com/influxdb/client/scala/index.html), [readme](./client-scala#influxdb-client-scala/) | 2.x  |
+| **[osgi](./client-osgi)**  | The reference OSGi (R6) client embedding Java and reactive clients and providing standard features (declarative services, configuration, event processing) for the InfluxDB 2.x.  | [javadoc](https://influxdata.github.io/influxdb-client-java/influxdb-client-osgi/apidocs/index.html), [readme](./client-osgi)  | 2.x  |
+| **[karaf](./karaf)**  | The Apache Karaf feature definition for the InfluxDB 2.x.  | [readme](./karaf)  | 2.x  |
 
 There is also possibility to use the Flux language over the InfluxDB 1.7+ provided by:
 

client-core/pom.xml

@@ -28,7 +28,7 @@
  <parent>
  <artifactId>influxdb-client</artifactId>
  <groupId>com.influxdb</groupId>
- <version>6.13.0-SNAPSHOT</version>
+ <version>7.0.0-SNAPSHOT</version>
  </parent>
 
  <artifactId>influxdb-client-core</artifactId>

client-kotlin/pom.xml

@@ -26,7 +26,7 @@
  <parent>
  <artifactId>influxdb-client</artifactId>
  <groupId>com.influxdb</groupId>
- <version>6.13.0-SNAPSHOT</version>
+ <version>7.0.0-SNAPSHOT</version>
  </parent>
  <modelVersion>4.0.0</modelVersion>
 

client-legacy/pom.xml

@@ -28,7 +28,7 @@
  <parent>
  <groupId>com.influxdb</groupId>
  <artifactId>influxdb-client</artifactId>
- <version>6.13.0-SNAPSHOT</version>
+ <version>7.0.0-SNAPSHOT</version>
  </parent>
 
  <artifactId>influxdb-client-flux</artifactId>

client-osgi/pom.xml

@@ -28,7 +28,7 @@
  <parent>
  <artifactId>influxdb-client</artifactId>
  <groupId>com.influxdb</groupId>
- <version>6.13.0-SNAPSHOT</version>
+ <version>7.0.0-SNAPSHOT</version>
  </parent>
 
  <artifactId>influxdb-client-osgi</artifactId>

client-reactive/pom.xml

@@ -26,7 +26,7 @@
  <parent>
  <artifactId>influxdb-client</artifactId>
  <groupId>com.influxdb</groupId>
- <version>6.13.0-SNAPSHOT</version>
+ <version>7.0.0-SNAPSHOT</version>
  </parent>
  <modelVersion>4.0.0</modelVersion>
 

client-scala/README.md

@@ -2,7 +2,7 @@
 
 [![ScalaDoc](https://img.shields.io/badge/Scaladoc-link-brightgreen.svg)](https://influxdata.github.io/influxdb-client-java/client-scala/cross/influxdb-client-scala_2.13/scaladocs/com/influxdb/client/scala/index.html)
 
-The reference Scala client that allows query and write for the InfluxDB 2.x by [Akka Streams](https://doc.akka.io/docs/akka/2.6/stream/).
+The reference Scala client that allows query and write for the InfluxDB 2.x by [Pekko Streams](https://pekko.apache.org/docs/pekko/current/stream/index.html).
 The client is cross-built against Scala `2.12` and `2.13`.
 
 ## Documentation
@@ -21,15 +21,15 @@ This section contains links to the client library documentation.
 
 ## Queries
 
-The [QueryScalaApi](https://influxdata.github.io/influxdb-client-java/client-scala/cross/influxdb-client-scala_2.13/scaladocs/com/influxdb/client/scala/QueryScalaApi.html) is based on the [Akka Streams](https://doc.akka.io/docs/akka/2.6/stream/). 
+The [QueryScalaApi](https://influxdata.github.io/influxdb-client-java/client-scala/cross/influxdb-client-scala_2.13/scaladocs/com/influxdb/client/scala/QueryScalaApi.html) is based on the [Pekko Streams](https://pekko.apache.org/docs/pekko/current/stream/index.html). 
 
 The following example demonstrates querying using the Flux language:
 
 ```scala
 package example
 
-import akka.actor.ActorSystem
-import akka.stream.scaladsl.Sink
+import org.apache.pekko.actor.ActorSystem
+import org.apache.pekko.stream.scaladsl.Sink
 import com.influxdb.client.scala.InfluxDBClientScalaFactory
 import com.influxdb.query.FluxRecord
 
@@ -77,8 +77,8 @@ It is possible to parse a result line-by-line using the `queryRaw` method:
 ```scala
 package example
 
-import akka.actor.ActorSystem
-import akka.stream.scaladsl.Sink
+import org.apache.pekko.actor.ActorSystem
+import org.apache.pekko.stream.scaladsl.Sink
 import com.influxdb.client.scala.InfluxDBClientScalaFactory
 
 import scala.concurrent.Await
@@ -204,8 +204,8 @@ package example
 
 import java.time.temporal.ChronoUnit
 
-import akka.actor.ActorSystem
-import akka.stream.scaladsl.Sink
+import org.apache.pekko.actor.ActorSystem
+import org.apache.pekko.stream.scaladsl.Sink
 import com.influxdb.client.scala.InfluxDBClientScalaFactory
 import com.influxdb.query.FluxRecord
 import com.influxdb.query.dsl.Flux

client-scala/cross/2.12/pom.xml

@@ -26,7 +26,7 @@
  <parent>
  <artifactId>influxdb-client</artifactId>
  <groupId>com.influxdb</groupId>
- <version>6.13.0-SNAPSHOT</version>
+ <version>7.0.0-SNAPSHOT</version>
  <relativePath>../../../pom.xml</relativePath>
  </parent>
  <modelVersion>4.0.0</modelVersion>
@@ -36,7 +36,7 @@
 
  <name>The Scala InfluxDB 2.x Client [Scala 2.12]</name>
  <description>
- The reference Scala client that allows query and write for the InfluxDB 2.x by Akka Streams.
+ The reference Scala client that allows query and write for the InfluxDB 2.x by Pekko Streams.
  </description>
 
  <url>https://github.com/influxdata/influxdb-client-java/tree/master/client-scala</url>
@@ -173,9 +173,9 @@
  </dependency>
 
  <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-stream_2.12</artifactId>
- <version>${akka.version}</version>
+ <groupId>org.apache.pekko</groupId>
+ <artifactId>pekko-stream_2.12</artifactId>
+ <version>${pekko.version}</version>
  <exclusions>
  <exclusion>
  <groupId>com.typesafe</groupId>
@@ -193,9 +193,9 @@
  </dependency>
 
  <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-testkit_2.12</artifactId>
- <version>${akka.version}</version>
+ <groupId>org.apache.pekko</groupId>
+ <artifactId>pekko-testkit_2.12</artifactId>
+ <version>${pekko.version}</version>
  <scope>test</scope>
  <exclusions>
  <exclusion>
@@ -206,9 +206,9 @@
  </dependency>
 
  <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-stream-testkit_2.12</artifactId>
- <version>${akka.version}</version>
+ <groupId>org.apache.pekko</groupId>
+ <artifactId>pekko-stream-testkit_2.12</artifactId>
+ <version>${pekko.version}</version>
  <scope>test</scope>
  <exclusions>
  <exclusion>

client-scala/cross/2.13/pom.xml

@@ -26,7 +26,7 @@
  <parent>
  <artifactId>influxdb-client</artifactId>
  <groupId>com.influxdb</groupId>
- <version>6.13.0-SNAPSHOT</version>
+ <version>7.0.0-SNAPSHOT</version>
  <relativePath>../../../pom.xml</relativePath>
  </parent>
  <modelVersion>4.0.0</modelVersion>
@@ -36,7 +36,7 @@
 
  <name>The Scala InfluxDB 2.x Client [Scala 2.13]</name>
  <description>
- The reference Scala client that allows query and write for the InfluxDB 2.x by Akka Streams.
+ The reference Scala client that allows query and write for the InfluxDB 2.x by Pekko Streams.
  </description>
 
  <url>https://github.com/influxdata/influxdb-client-java/tree/master/client-scala</url>
@@ -171,9 +171,9 @@
  </dependency>
 
  <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-stream_2.13</artifactId>
- <version>${akka.version}</version>
+ <groupId>org.apache.pekko</groupId>
+ <artifactId>pekko-stream_2.13</artifactId>
+ <version>${pekko.version}</version>
  <exclusions>
  <exclusion>
  <groupId>com.typesafe</groupId>
@@ -191,9 +191,9 @@
  </dependency>
 
  <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-testkit_2.13</artifactId>
- <version>${akka.version}</version>
+ <groupId>org.apache.pekko</groupId>
+ <artifactId>pekko-testkit_2.13</artifactId>
+ <version>${pekko.version}</version>
  <scope>test</scope>
  <exclusions>
  <exclusion>
@@ -204,9 +204,9 @@
  </dependency>
 
  <dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-stream-testkit_2.13</artifactId>
- <version>${akka.version}</version>
+ <groupId>org.apache.pekko</groupId>
+ <artifactId>pekko-stream-testkit_2.13</artifactId>
+ <version>${pekko.version}</version>
  <scope>test</scope>
  <exclusions>
  <exclusion>