This PR migrates Ditto to Apache Pekko

.github/workflows/maven.yml

@@ -42,4 +42,4 @@ jobs:
           cache: 'maven'
 
       - name: Build with Maven
-        run: mvn package javadoc:jar source:jar --batch-mode --errors --quiet -DcreateJavadoc=true -Dakka.test.single-expect-default=10s --file pom.xml -Dbuild.environment=Github
+        run: mvn package javadoc:jar source:jar --batch-mode --errors --quiet -DcreateJavadoc=true -Dpekko.test.single-expect-default=10s --file pom.xml -Dbuild.environment=Github

base/model/pom.xml

@@ -47,8 +47,8 @@
             <scope>test</scope>
         </dependency>
         <dependency>
-            <groupId>com.typesafe.akka</groupId>
-            <artifactId>akka-testkit_${scala.version}</artifactId>
+            <groupId>org.apache.pekko</groupId>
+            <artifactId>pekko-testkit_${scala.version}</artifactId>
             <scope>test</scope>
         </dependency>
     </dependencies>

base/model/src/main/java/org/eclipse/ditto/base/model/headers/DittoHeaderDefinition.java

@@ -441,7 +441,7 @@ public enum DittoHeaderDefinition implements HeaderDefinition {
             HeaderValueValidators.getBooleanValidator()),
 
     /**
-     * Internal header passing through the Akka address of an {@code AcknowledgementAggregatorActor} which was started
+     * Internal header passing through the Pekko address of an {@code AcknowledgementAggregatorActor} which was started
      * at an edge (gateway/connectivity) and is awaiting {@code Acknowledgement}s which can be sent to it by using
      * this address in an {@code ActorSelection}.
      *

base/model/src/main/java/org/eclipse/ditto/base/model/headers/JsonFieldSelectorValidator.java

@@ -30,7 +30,7 @@
 final class JsonFieldSelectorValidator extends AbstractHeaderValueValidator {
 
     /**
-     * Don't configure URL decoding as JsonParseOptions because Akka-Http already decodes the fields-param and we would
+     * Don't configure URL decoding as JsonParseOptions because Pekko-Http already decodes the fields-param and we would
      * decode twice.
      */
     private static final JsonParseOptions JSON_FIELD_SELECTOR_PARSE_OPTIONS = JsonFactory.newParseOptionsBuilder()

base/model/src/test/java/org/eclipse/ditto/base/model/signals/DittoTestSystem.java

@@ -12,8 +12,9 @@
  */
 package org.eclipse.ditto.base.model.signals;
 
-import akka.actor.ActorSystem;
-import akka.testkit.javadsl.TestKit;
+import org.apache.pekko.actor.ActorSystem;
+import org.apache.pekko.testkit.javadsl.TestKit;
+
 
 /**
  * Manage creation and termination of actor systems for tests.

base/service/pom.xml

@@ -68,35 +68,35 @@
             <artifactId>logback-classic</artifactId>
         </dependency>
         <dependency>
-            <groupId>com.typesafe.akka</groupId>
-            <artifactId>akka-actor_${scala.version}</artifactId>
+            <groupId>org.apache.pekko</groupId>
+            <artifactId>pekko-actor_${scala.version}</artifactId>
         </dependency>
 
         <dependency>
-            <groupId>com.lightbend.akka.management</groupId>
-            <artifactId>akka-management_${scala.version}</artifactId>
+            <groupId>org.apache.pekko</groupId>
+            <artifactId>pekko-management_${scala.version}</artifactId>
         </dependency>
         <dependency>
-            <groupId>com.lightbend.akka.management</groupId>
-            <artifactId>akka-management-cluster-bootstrap_${scala.version}</artifactId>
+            <groupId>org.apache.pekko</groupId>
+            <artifactId>pekko-management-cluster-bootstrap_${scala.version}</artifactId>
         </dependency>
         <dependency>
-            <groupId>com.lightbend.akka.management</groupId>
-            <artifactId>akka-management-cluster-http_${scala.version}</artifactId>
+            <groupId>org.apache.pekko</groupId>
+            <artifactId>pekko-management-cluster-http_${scala.version}</artifactId>
         </dependency>
 
         <dependency>
-            <groupId>com.lightbend.akka.discovery</groupId>
-            <artifactId>akka-discovery-kubernetes-api_${scala.version}</artifactId>
+            <groupId>org.apache.pekko</groupId>
+            <artifactId>pekko-discovery-kubernetes-api_${scala.version}</artifactId>
         </dependency>
         <dependency>
-            <groupId>com.lightbend.akka.management</groupId>
-            <artifactId>akka-lease-kubernetes_${scala.version}</artifactId>
+            <groupId>org.apache.pekko</groupId>
+            <artifactId>pekko-lease-kubernetes_${scala.version}</artifactId>
         </dependency>
 
         <dependency>
             <groupId>com.github.scullxbones</groupId>
-            <artifactId>akka-persistence-mongo-common_${scala.version}</artifactId>
+            <artifactId>pekko-persistence-mongodb_${scala.version}</artifactId>
         </dependency>
 
         <dependency>
@@ -126,8 +126,8 @@
 
         <!-- test scope -->
         <dependency>
-            <groupId>com.typesafe.akka</groupId>
-            <artifactId>akka-testkit_${scala.version}</artifactId>
+            <groupId>org.apache.pekko</groupId>
+            <artifactId>pekko-testkit_${scala.version}</artifactId>
             <scope>test</scope>
         </dependency>
         <dependency>

base/service/src/main/java/org/eclipse/ditto/base/service/DittoService.java

@@ -47,17 +47,17 @@
 import com.typesafe.config.ConfigValue;
 import com.typesafe.config.ConfigValueFactory;
 
-import akka.Done;
-import akka.actor.ActorRef;
-import akka.actor.ActorSystem;
-import akka.actor.CoordinatedShutdown;
-import akka.actor.Props;
-import akka.cluster.Cluster;
-import akka.cluster.pubsub.DistributedPubSub;
-import akka.http.javadsl.Http;
-import akka.http.javadsl.model.Uri;
-import akka.management.cluster.bootstrap.ClusterBootstrap;
-import akka.management.javadsl.AkkaManagement;
+import org.apache.pekko.Done;
+import org.apache.pekko.actor.ActorRef;
+import org.apache.pekko.actor.ActorSystem;
+import org.apache.pekko.actor.CoordinatedShutdown;
+import org.apache.pekko.actor.Props;
+import org.apache.pekko.cluster.Cluster;
+import org.apache.pekko.cluster.pubsub.DistributedPubSub;
+import org.apache.pekko.http.javadsl.Http;
+import org.apache.pekko.http.javadsl.model.Uri;
+import org.apache.pekko.management.cluster.bootstrap.ClusterBootstrap;
+import org.apache.pekko.management.javadsl.PekkoManagement;
 import ch.qos.logback.classic.LoggerContext;
 import kamon.Kamon;
 import kamon.prometheus.PrometheusReporter;
@@ -71,11 +71,11 @@
  * <ol>
  * <li>{@link #determineRawConfig()},</li>
  * <li>{@link #createActorSystem(com.typesafe.config.Config)},</li>
- * <li>{@link #startStatusSupplierActor(akka.actor.ActorSystem)},</li>
- * <li>{@link #startServiceRootActors(akka.actor.ActorSystem, org.eclipse.ditto.base.service.config.ServiceSpecificConfig)}.
+ * <li>{@link #startStatusSupplierActor(org.apache.pekko.actor.ActorSystem)},</li>
+ * <li>{@link #startServiceRootActors(org.apache.pekko.actor.ActorSystem, org.eclipse.ditto.base.service.config.ServiceSpecificConfig)}.
  * <ol>
- * <li>{@link #getMainRootActorProps(org.eclipse.ditto.base.service.config.ServiceSpecificConfig, akka.actor.ActorRef)},</li>
- * <li>{@link #startMainRootActor(akka.actor.ActorSystem, akka.actor.Props)},</li>
+ * <li>{@link #getMainRootActorProps(org.eclipse.ditto.base.service.config.ServiceSpecificConfig, org.apache.pekko.actor.ActorRef)},</li>
+ * <li>{@link #startMainRootActor(org.apache.pekko.actor.ActorSystem, org.apache.pekko.actor.Props)},</li>
  * </ol>
  * </li>
  * </ol>
@@ -95,7 +95,7 @@ public abstract class DittoService<C extends ServiceSpecificConfig> {
      */
     public static final String DITTO_CONFIG_PATH = ScopedConfig.DITTO_SCOPE;
 
-    protected static final String MONGO_URI_CONFIG_PATH = "akka.contrib.persistence.mongodb.mongo.mongouri";
+    protected static final String MONGO_URI_CONFIG_PATH = "pekko.contrib.persistence.mongodb.mongo.mongouri";
 
     protected final Config rawConfig;
     protected final C serviceSpecificConfig;
@@ -207,15 +207,15 @@ private static ScopedConfig getDittoConfigOrEmpty(final Config rawConfig) {
      */
     private ActorSystem doStart() {
         logRuntimeParameters();
-        final var actorSystemConfig = appendDittoInfo(appendAkkaPersistenceMongoUriToRawConfig());
+        final var actorSystemConfig = appendDittoInfo(appendPekkoPersistenceMongoUriToRawConfig());
         startKamon();
         final var actorSystem = createActorSystem(actorSystemConfig);
         initializeActorSystem(actorSystem);
         startKamonPrometheusHttpEndpoint(actorSystem);
         return actorSystem;
     }
 
-    protected Config appendAkkaPersistenceMongoUriToRawConfig() {
+    protected Config appendPekkoPersistenceMongoUriToRawConfig() {
         return rawConfig;
     }
 
@@ -255,9 +255,9 @@ private void startPrometheusReporter() {
     }
 
     /**
-     * Starts the Akka actor system as well as all required actors.
+     * Starts the Pekko actor system as well as all required actors.
      * <p>
-     * May be overridden to change the way how the Akka actor system and actors are started. <em>Note: If this method is
+     * May be overridden to change the way how the Pekko actor system and actors are started. <em>Note: If this method is
      * overridden, none of the following mentioned methods and their descendant methods will be called
      * automatically:</em>
      * </p>
@@ -267,10 +267,10 @@ private void startPrometheusReporter() {
      * <li>{@link #startServiceRootActors(ActorSystem, org.eclipse.ditto.base.service.config.ServiceSpecificConfig)}.</li>
      * </ul>
      *
-     * @param actorSystem the Akka ActorSystem to be initialized.
+     * @param actorSystem the Pekko ActorSystem to be initialized.
      */
     private void initializeActorSystem(final ActorSystem actorSystem) {
-        startAkkaManagement(actorSystem);
+        startPekkoManagement(actorSystem);
         startClusterBootstrap(actorSystem);
 
         startStatusSupplierActor(actorSystem);
@@ -310,7 +310,7 @@ private void startKamonPrometheusHttpEndpoint(final ActorSystem actorSystem) {
     }
 
     /**
-     * Creates the Akka actor system. May be overridden to change the way how the actor system is created.
+     * Creates the Pekko actor system. May be overridden to change the way how the actor system is created.
      *
      * @param config the configuration settings of this service.
      * @return the actor system.
@@ -319,15 +319,15 @@ private ActorSystem createActorSystem(final Config config) {
         return ActorSystem.create(CLUSTER_NAME, config);
     }
 
-    private void startAkkaManagement(final ActorSystem actorSystem) {
-        logger.info("Starting AkkaManagement ...");
-        final var akkaManagement = AkkaManagement.get(actorSystem);
-        final CompletionStage<Uri> startPromise = akkaManagement.start();
+    private void startPekkoManagement(final ActorSystem actorSystem) {
+        logger.info("Starting PekkoManagement ...");
+        final var pekkoManagement = PekkoManagement.get(actorSystem);
+        final CompletionStage<Uri> startPromise = pekkoManagement.start();
         startPromise.whenComplete((uri, throwable) -> {
             if (null != throwable) {
-                logger.error("Error during start of AkkaManagement: <{}>!", throwable.getMessage(), throwable);
+                logger.error("Error during start of PekkoManagement: <{}>!", throwable.getMessage(), throwable);
             } else {
-                logger.info("Started AkkaManagement on URI <{}>.", uri);
+                logger.info("Started PekkoManagement on URI <{}>.", uri);
             }
         });
     }
@@ -342,7 +342,7 @@ private void startClusterBootstrap(final ActorSystem actorSystem) {
      * Starts the {@link org.eclipse.ditto.internal.utils.health.status.StatusSupplierActor}.
      * May be overridden to change the way how the actor is started.
      *
-     * @param actorSystem Akka actor system for starting actors.
+     * @param actorSystem Pekko actor system for starting actors.
      */
     private void startStatusSupplierActor(final ActorSystem actorSystem) {
         startActor(actorSystem, StatusSupplierActor.props(rootActorName), StatusSupplierActor.ACTOR_NAME);
@@ -361,7 +361,7 @@ private void logStartingActor(final String actorName) {
      * Starts the {@link org.eclipse.ditto.base.service.devops.DevOpsCommandsActor}.
      * May be overridden to change the way how the actor is started.
      *
-     * @param actorSystem Akka actor system for starting actors.
+     * @param actorSystem Pekko actor system for starting actors.
      */
     private void startDevOpsCommandsActor(final ActorSystem actorSystem) {
         startActor(actorSystem, DevOpsCommandsActor.props(LogbackLoggingFacade.newInstance(), serviceName,
@@ -375,11 +375,11 @@ private void startDevOpsCommandsActor(final ActorSystem actorSystem) {
      * is overridden, the following methods will not be called automatically:</em>
      * </p>
      * <ul>
-     * <li>{@link #getMainRootActorProps(org.eclipse.ditto.base.service.config.ServiceSpecificConfig, akka.actor.ActorRef)},</li>
-     * <li>{@link #startMainRootActor(akka.actor.ActorSystem, akka.actor.Props)},</li>
+     * <li>{@link #getMainRootActorProps(org.eclipse.ditto.base.service.config.ServiceSpecificConfig, org.apache.pekko.actor.ActorRef)},</li>
+     * <li>{@link #startMainRootActor(org.apache.pekko.actor.ActorSystem, org.apache.pekko.actor.Props)},</li>
      * </ul>
      *
-     * @param actorSystem Akka actor system for starting actors.
+     * @param actorSystem Pekko actor system for starting actors.
      * @param serviceSpecificConfig the configuration settings of this service.
      */
     private void startServiceRootActors(final ActorSystem actorSystem, final C serviceSpecificConfig) {
@@ -437,7 +437,7 @@ private static ActorRef getDistributedPubSubMediatorActor(final ActorSystem acto
      * Starts the main root actor of this service. May be overridden to change the way of starting this service's root
      * actor.
      *
-     * @param actorSystem Akka actor system for starting actors.
+     * @param actorSystem Pekko actor system for starting actors.
      * @param mainRootActorProps the Props of the main root actor.
      */
     private ActorRef startMainRootActor(final ActorSystem actorSystem, final Props mainRootActorProps) {
@@ -452,9 +452,9 @@ private void setUpCoordinatedShutdown(final ActorSystem actorSystem) {
                     logger.info("Initiated coordinated shutdown; gracefully shutting down ...");
                     coordinatedShutdown.getShutdownReason().ifPresent(reason ->
                             logger.info("Shutdown reason was - <{}>", reason));
-                    final CompletionStage<Done> stop = AkkaManagement.get(actorSystem).stop();
+                    final CompletionStage<Done> stop = PekkoManagement.get(actorSystem).stop();
                     return stop.thenApply(done -> {
-                        logger.info("AkkaManagement stopped!");
+                        logger.info("PekkoManagement stopped!");
                         return done;
                     });
 

base/service/src/main/java/org/eclipse/ditto/base/service/DockerSwarmServiceDiscovery.java

@@ -20,11 +20,11 @@
 import java.util.concurrent.TimeoutException;
 import java.util.stream.Collectors;
 
-import akka.actor.ExtendedActorSystem;
-import akka.discovery.Lookup;
-import akka.discovery.ServiceDiscovery;
-import akka.dispatch.Futures;
-import akka.pattern.Patterns;
+import org.apache.pekko.actor.ExtendedActorSystem;
+import org.apache.pekko.discovery.Lookup;
+import org.apache.pekko.discovery.ServiceDiscovery;
+import org.apache.pekko.dispatch.Futures;
+import org.apache.pekko.pattern.Patterns;
 import scala.Option;
 import scala.collection.JavaConverters;
 import scala.concurrent.Future;
@@ -35,7 +35,7 @@
  * <p>
  * One speciality of a Docker swarm based cluster is that the Docker swarm DNS sets a TTL of DNS entries to 600 seconds
  * (10 minutes) - so if a cluster forms and not all DNS entries are "there" from the beginning, it takes 10 minutes
- * until DNS caches used by the default Akka {@link akka.discovery.dns.DnsServiceDiscovery DnsServiceDiscovery} are
+ * until DNS caches used by the default Pekko {@link org.apache.pekko.discovery.dns.DnsServiceDiscovery DnsServiceDiscovery} are
  * evicted and another DNS lookup is done.
  * </p>
  * This implementation does not cache DNS entries and can therefore be used for bootstrapping in Docker swarm.

base/service/src/main/java/org/eclipse/ditto/base/service/MainMethodExceptionHandler.java

@@ -21,7 +21,7 @@
 
 import org.slf4j.Logger;
 
-import akka.actor.ActorSystem;
+import org.apache.pekko.actor.ActorSystem;
 
 /**
  * This class wraps the execution of a Runnable for catching {@code Throwable}s. The Runnable is assumed to be the

base/service/src/main/java/org/eclipse/ditto/base/service/NoOpRootActorStarter.java

@@ -14,7 +14,7 @@
 
 import com.typesafe.config.Config;
 
-import akka.actor.ActorSystem;
+import org.apache.pekko.actor.ActorSystem;
 
 /**
  * Root actor starter that does purposefully nothing.

base/service/src/main/java/org/eclipse/ditto/base/service/NoOpRootChildActorStarter.java

@@ -14,8 +14,8 @@
 
 import com.typesafe.config.Config;
 
-import akka.actor.ActorContext;
-import akka.actor.ActorSystem;
+import org.apache.pekko.actor.ActorContext;
+import org.apache.pekko.actor.ActorSystem;
 
 /**
  * Root actor child starter that does purposefully nothing.

base/service/src/main/java/org/eclipse/ditto/base/service/RootActorStarter.java

@@ -19,7 +19,7 @@
 
 import com.typesafe.config.Config;
 
-import akka.actor.ActorSystem;
+import org.apache.pekko.actor.ActorSystem;
 
 /**
  * Extension to start custom root actors in service.

base/service/src/main/java/org/eclipse/ditto/base/service/RootChildActorStarter.java

@@ -19,8 +19,8 @@
 
 import com.typesafe.config.Config;
 
-import akka.actor.ActorContext;
-import akka.actor.ActorSystem;
+import org.apache.pekko.actor.ActorContext;
+import org.apache.pekko.actor.ActorSystem;
 
 /**
  * Extension to start custom child actors in root actor.

base/service/src/main/java/org/eclipse/ditto/base/service/UriEncoding.java

@@ -34,7 +34,7 @@ public final class UriEncoding {
     private static final IntPredicate ALLOWED_IN_PATH_SEGMENT = UriEncoding::isPchar;
     /*
      * Workaround: '+' needs to be escaped to '%2B', otherwise it will be recognized as blank when decoding with MIME
-     * format {@code application/x-www-form-urlencoded} - what most servers do (such as akka-http).
+     * format {@code application/x-www-form-urlencoded} - what most servers do (such as pekko-http).
      */
     private static final IntPredicate ALLOWED_IN_QUERY = c -> c != '+' && (isPchar(c) || '/' == c || '?' == c);
     private static final IntPredicate ALLOWED_IN_QUERY_PARAM =