diff --git a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala
index 2a97e313234..8057b0e8e66 100644
--- a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala
+++ b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/BehaviorTestKit.scala
@@ -177,7 +177,7 @@ abstract class BehaviorTestKit[T] {
   def expectEffect(expectedEffect: Effect): Unit
 
   /**
-   * Asserts that the oldest effect is an instance of of class T. Consumes and returns the concrete effect for
+   * Asserts that the oldest effect is an instance of class T. Consumes and returns the concrete effect for
    * further direct assertions.
    */
   def expectEffectClass[U <: Effect](effectClass: Class[U]): U
diff --git a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala
index bc4467aca48..69876fc9b4e 100644
--- a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala
+++ b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/javadsl/TestInbox.scala
@@ -62,7 +62,7 @@ abstract class TestInbox[T] {
   def receiveMessage(): T
 
   /**
-   * Assert and remove the the oldest message.
+   * Assert and remove the oldest message.
    */
   def expectMessage(expectedMessage: T): TestInbox[T]
 
diff --git a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala
index f6194998355..8b9086344ec 100644
--- a/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala
+++ b/actor-testkit-typed/src/main/scala/org/apache/pekko/actor/testkit/typed/scaladsl/TestInbox.scala
@@ -61,7 +61,7 @@ trait TestInbox[T] {
   def receiveMessage(): T
 
   /**
-   * Assert and remove the the oldest message.
+   * Assert and remove the oldest message.
    */
   def expectMessage(expectedMessage: T): TestInbox[T]
 
diff --git a/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala b/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala
index d509c559582..686cd47136b 100644
--- a/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala
+++ b/actor-tests/src/test/scala/org/apache/pekko/io/UdpConnectedIntegrationSpec.scala
@@ -162,7 +162,7 @@ class UdpConnectedIntegrationSpec extends PekkoSpec("""
       clientCommander ! UdpConnected.Send(ByteString("data to trigger fail"), 2)
       expectMsg(2)
 
-      // when a new server appears at the same port it it should be able to receive
+      // when a new server appears at the same port it should be able to receive
       val serverIncarnation2Handler = TestProbe()
       val serverIncarnation2 = bindUdp(serverAddress, serverIncarnation2Handler.ref)
       val dataToNewIncarnation = ByteString("Data to new incarnation")
diff --git a/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala b/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala
index 4248da6a68d..a94ba683680 100644
--- a/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala
+++ b/actor-tests/src/test/scala/org/apache/pekko/serialization/SerializeSpec.scala
@@ -223,7 +223,7 @@ class SerializeSpec extends PekkoSpec(SerializationTests.serializeConf) {
       ser.serializerFor(classOf[PlainMessage]).getClass should ===(classOf[NoopSerializer])
     }
 
-    "resolve serializer for message extending class with with binding" in {
+    "resolve serializer for message extending class with binding" in {
       ser.serializerFor(classOf[ExtendedPlainMessage]).getClass should ===(classOf[NoopSerializer])
     }
 
diff --git a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala
index 3cab20efceb..cf792d9a1c6 100644
--- a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala
+++ b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/SpawnProtocol.scala
@@ -47,7 +47,7 @@ object SpawnProtocol {
    * If `name` is an empty string an anonymous actor (with automatically generated name) will be created.
    *
    * If the `name` is already taken of an existing actor a unique name will be used by appending a suffix
-   * to the the `name`. The exact format or value of the suffix is an implementation detail that is
+   * to the `name`. The exact format or value of the suffix is an implementation detail that is
    * undefined. This means that reusing the same name for several actors will not result in
    * `InvalidActorNameException`, but it's better to use unique names to begin with.
    */
diff --git a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala
index 48214170871..2e8b008bee1 100644
--- a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala
+++ b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/delivery/internal/WorkPullingProducerControllerImpl.scala
@@ -664,7 +664,7 @@ private class WorkPullingProducerControllerImpl[A: ClassTag](
 
       case AskTimeout(outKey, outSeqNr) =>
         context.log.debug(
-          "Message seqNr [{}] sent to worker [{}] timed out. It will be be redelivered.",
+          "Message seqNr [{}] sent to worker [{}] timed out. It will be redelivered.",
           outSeqNr,
           outKey)
         Behaviors.same
diff --git a/actor/src/main/resources/reference.conf b/actor/src/main/resources/reference.conf
index 5b4add60f30..9a7cf7b62c8 100644
--- a/actor/src/main/resources/reference.conf
+++ b/actor/src/main/resources/reference.conf
@@ -595,7 +595,7 @@ pekko {
       # If the current runtime does not support virtual thread,
       # then the executor configured in "fallback" will be used.
       virtual-thread-executor {
-        #Please set the the underlying pool with system properties below:
+        #Please set the underlying pool with system properties below:
         #jdk.virtualThreadScheduler.parallelism
         #jdk.virtualThreadScheduler.maxPoolSize
         #jdk.virtualThreadScheduler.minRunnable
diff --git a/actor/src/main/scala/org/apache/pekko/actor/Stash.scala b/actor/src/main/scala/org/apache/pekko/actor/Stash.scala
index 823253f0ab9..104962a103f 100644
--- a/actor/src/main/scala/org/apache/pekko/actor/Stash.scala
+++ b/actor/src/main/scala/org/apache/pekko/actor/Stash.scala
@@ -254,7 +254,7 @@ private[pekko] trait StashSupport {
   /**
    * INTERNAL API.
    *
-   * Clears the stash and and returns all envelopes that have not been unstashed.
+   * Clears the stash and returns all envelopes that have not been unstashed.
    */
   @InternalStableApi
   private[pekko] def clearStash(): Vector[Envelope] = {
diff --git a/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala b/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala
index f5a973ef63e..e1ea980f3c8 100644
--- a/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala
+++ b/actor/src/main/scala/org/apache/pekko/actor/dungeon/TimerSchedulerImpl.scala
@@ -149,7 +149,7 @@ import pekko.util.OptionVal
         } else {
           // it was from an old timer that was enqueued in mailbox before canceled
           log.debug(
-            "Received timer [{}] from from old generation [{}], expected generation [{}], discarding",
+            "Received timer [{}] from old generation [{}], expected generation [{}], discarding",
             timerMsg.key,
             timerMsg.generation,
             t.generation)
diff --git a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala
index 3224d1674ec..b64fc1930d1 100644
--- a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala
+++ b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/ShardedDaemonProcessSettings.scala
@@ -88,7 +88,7 @@ final class ShardedDaemonProcessSettings @InternalApi private[pekko] (
   /**
    * Specifies that the ShardedDaemonProcess should run on nodes with a specific role.
    * If the role is not specified all nodes in the cluster are used. If the given role does
-   * not match the role of the current node the the ShardedDaemonProcess will not be started.
+   * not match the role of the current node the ShardedDaemonProcess will not be started.
    */
   def withRole(role: String): ShardedDaemonProcessSettings =
     copy(role = Option(role))
diff --git a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala
index b105fcdf128..1778f005a02 100644
--- a/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala
+++ b/cluster-sharding-typed/src/main/scala/org/apache/pekko/cluster/sharding/typed/delivery/internal/ShardingProducerControllerImpl.scala
@@ -573,7 +573,7 @@ private class ShardingProducerControllerImpl[A: ClassTag](
 
       case AskTimeout(outKey, outSeqNr) =>
         context.log.debug(
-          "Message seqNr [{}] sent to entity [{}] timed out. It will be be redelivered.",
+          "Message seqNr [{}] sent to entity [{}] timed out. It will be redelivered.",
           outSeqNr,
           outKey)
         Behaviors.same
diff --git a/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala b/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala
index 56a30704ee1..e05cf0d23d4 100644
--- a/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala
+++ b/cluster-sharding-typed/src/test/scala/org/apache/pekko/cluster/sharding/typed/delivery/ReliableDeliveryShardingSpec.scala
@@ -305,7 +305,7 @@ class ReliableDeliveryShardingSpec
       next8.entitiesWithDemand should ===(Set("entity-2"))
       next8.bufferedForEntitiesWithoutDemand should ===(Map("entity-1" -> 1))
 
-      // when new demand the buffered messages will be be sent
+      // when new demand the buffered messages will be sent
       seq5.producerController ! ProducerControllerImpl.Request(confirmedSeqNr = 5L, requestUpToSeqNr = 10, true, false)
       val seq6 = shardingProbe
         .fishForMessage(testKit.testKitSettings.dilated(3.seconds), "waiting for buffered msg-6 after renewed demand") {
diff --git a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala
index 538f5cde2de..b079f98d434 100644
--- a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala
+++ b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ShardCoordinator.scala
@@ -171,7 +171,7 @@ object ShardCoordinator {
   /**
    * Shard allocation strategy where start is called by the shard coordinator before any calls to
    * rebalance or allocate shard. This can be used if there is any expensive initialization to be done
-   * that you do not want to to in the constructor as it will happen on every node rather than just
+   * that you do not want to do in the constructor as it will happen on every node rather than just
    * the node that hosts the ShardCoordinator
    */
   trait StartableAllocationStrategy extends ShardAllocationStrategy {
diff --git a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala
index 37463335bc3..ea8ae11bb42 100644
--- a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala
+++ b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/ConcurrentStartupShardingSpec.scala
@@ -78,7 +78,7 @@ class ConcurrentStartupShardingSpec extends PekkoSpec(ConcurrentStartupShardingS
   if (!log.isDebugEnabled)
     system.eventStream.publish(Mute(DeadLettersFilter[Any]))
 
-  // The intended usage is to start sharding in one (or a few) places when the the ActorSystem
+  // The intended usage is to start sharding in one (or a few) places when the ActorSystem
   // is started and not to do it concurrently from many threads. However, we can do our best and when using
   // FJP the Await will create additional threads when needed.
   "Concurrent Sharding startup" must {
diff --git a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala
index 49edf1ccbf7..6d7c4ced175 100644
--- a/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala
+++ b/cluster-sharding/src/test/scala/org/apache/pekko/cluster/sharding/PersistentShardingMigrationSpec.scala
@@ -42,7 +42,7 @@ object PersistentShardingMigrationSpec {
         remember-entities-store = "eventsourced"
 
         # this forces the remembered entity store to use persistence
-        # is is deprecated
+        # is deprecated
         state-store-mode = "persistence"
        
         # make sure we test snapshots
diff --git a/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala b/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala
index 6a1a2bf6eed..0fca6107e39 100644
--- a/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala
+++ b/cluster-tools/src/main/scala/org/apache/pekko/cluster/singleton/ClusterSingletonManager.scala
@@ -219,7 +219,7 @@ object ClusterSingletonManager {
     case object HandOverDone extends ClusterSingletonMessage
 
     /**
-     * Sent from from previous oldest to new oldest to
+     * Sent from previous oldest to new oldest to
      * initiate the normal hand-over process.
      * Especially useful when new node joins and becomes
      * oldest immediately, without knowing who was previous
diff --git a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala
index 3910c3b0882..8fbaa0f835a 100644
--- a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala
+++ b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/javadsl/ReplicatorMessageAdapter.scala
@@ -101,7 +101,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
    * `responseAdapter` function.
    *
    * Note that `createRequest` is a function that creates the `Update` message from the provided
-   * `ActorRef[UpdateResponse]` that the the replicator will send the response message back through.
+   * `ActorRef[UpdateResponse]` that the replicator will send the response message back through.
    * Use that `ActorRef[UpdateResponse]` as the `replyTo` parameter in the `Update` message.
    */
   def askUpdate(
@@ -120,7 +120,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
    * `responseAdapter` function.
    *
    * Note that `createRequest` is a function that creates the `Get` message from the provided
-   * `ActorRef[GetResponse]` that the the replicator will send the response message back through.
+   * `ActorRef[GetResponse]` that the replicator will send the response message back through.
    * Use that `ActorRef[GetResponse]` as the `replyTo` parameter in the `Get` message.
    */
   @nowarn
@@ -140,7 +140,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
    * `responseAdapter` function.
    *
    * Note that `createRequest` is a function that creates the `Delete` message from the provided
-   * `ActorRef[DeleteResponse]` that the the replicator will send the response message back through.
+   * `ActorRef[DeleteResponse]` that the replicator will send the response message back through.
    * Use that `ActorRef[DeleteResponse]` as the `replyTo` parameter in the `Delete` message.
    */
   def askDelete(
@@ -159,7 +159,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
    * `responseAdapter` function.
    *
    * Note that `createRequest` is a function that creates the `GetReplicaCount` message from the provided
-   * `ActorRef[ReplicaCount]` that the the replicator will send the response message back through.
+   * `ActorRef[ReplicaCount]` that the replicator will send the response message back through.
    * Use that `ActorRef[ReplicaCount]` as the `replyTo` parameter in the `GetReplicaCount` message.
    */
   def askReplicaCount(
diff --git a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala
index 2544515e80d..e30ba2a1fb7 100644
--- a/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala
+++ b/cluster-typed/src/main/scala/org/apache/pekko/cluster/ddata/typed/scaladsl/ReplicatorMessageAdapter.scala
@@ -104,7 +104,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
    * `responseAdapter` function.
    *
    * Note that `createRequest` is a function that creates the `Update` message from the provided
-   * `ActorRef[UpdateResponse]` that the the replicator will send the response message back through.
+   * `ActorRef[UpdateResponse]` that the replicator will send the response message back through.
    * Use that `ActorRef[UpdateResponse]` as the `replyTo` parameter in the `Update` message.
    */
   def askUpdate(
@@ -123,7 +123,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
    * `responseAdapter` function.
    *
    * Note that `createRequest` is a function that creates the `Get` message from the provided
-   * `ActorRef[GetResponse]` that the the replicator will send the response message back through.
+   * `ActorRef[GetResponse]` that the replicator will send the response message back through.
    * Use that `ActorRef[GetResponse]` as the `replyTo` parameter in the `Get` message.
    */
   def askGet(
@@ -141,7 +141,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
    * `responseAdapter` function.
    *
    * Note that `createRequest` is a function that creates the `Delete` message from the provided
-   * `ActorRef[DeleteResponse]` that the the replicator will send the response message back through.
+   * `ActorRef[DeleteResponse]` that the replicator will send the response message back through.
    * Use that `ActorRef[DeleteResponse]` as the `replyTo` parameter in the `Delete` message.
    */
   def askDelete(
@@ -160,7 +160,7 @@ class ReplicatorMessageAdapter[A, B <: ReplicatedData](
    * `responseAdapter` function.
    *
    * Note that `createRequest` is a function that creates the `GetReplicaCount` message from the provided
-   * `ActorRef[ReplicaCount]` that the the replicator will send the response message back through.
+   * `ActorRef[ReplicaCount]` that the replicator will send the response message back through.
    * Use that `ActorRef[ReplicaCount]` as the `replyTo` parameter in the `GetReplicaCount` message.
    */
   def askReplicaCount(
diff --git a/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala b/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala
index 1fd9bd911b7..2a13a1a4553 100644
--- a/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala
+++ b/cluster/src/main/scala/org/apache/pekko/cluster/Cluster.scala
@@ -452,7 +452,7 @@ class Cluster(val system: ExtendedActorSystem) extends Extension {
   /**
    * The supplied thunk will be run, once, when current cluster member is `Removed`.
    * If the cluster has already been shutdown the thunk will run on the caller thread immediately.
-   * If this is called "at the same time" as `shutdown()` there is a possibility that the the thunk
+   * If this is called "at the same time" as `shutdown()` there is a possibility that the thunk
    * is not invoked. It's often better to use [[pekko.actor.CoordinatedShutdown]] for this purpose.
    */
   def registerOnMemberRemoved[T](code: => T): Unit =
@@ -461,7 +461,7 @@ class Cluster(val system: ExtendedActorSystem) extends Extension {
   /**
    * Java API: The supplied thunk will be run, once, when current cluster member is `Removed`.
    * If the cluster has already been shutdown the thunk will run on the caller thread immediately.
-   * If this is called "at the same time" as `shutdown()` there is a possibility that the the thunk
+   * If this is called "at the same time" as `shutdown()` there is a possibility that the thunk
    * is not invoked. It's often better to use [[pekko.actor.CoordinatedShutdown]] for this purpose.
    */
   def registerOnMemberRemoved(callback: Runnable): Unit = {
diff --git a/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala b/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala
index 4de96915bf0..ccc209d5e2c 100644
--- a/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala
+++ b/cluster/src/main/scala/org/apache/pekko/cluster/sbr/DowningStrategy.scala
@@ -392,7 +392,7 @@ import pekko.coordination.lease.scaladsl.Lease
  * INTERNAL API
  *
  * Down the unreachable nodes if the current node is in the majority part based the last known
- * membership information. Otherwise down the reachable nodes, i.e. the own part. If the the
+ * membership information. Otherwise down the reachable nodes, i.e. the own part. If the
  * parts are of equal size the part containing the node with the lowest address is kept.
  *
  * If the `role` is defined the decision is based only on members with that `role`.
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala
index 086a42f1e7d..9677f2d4599 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/JoinConfigCompatCheckerSpec.scala
@@ -234,7 +234,7 @@ class JoinConfigCompatCheckerSpec extends PekkoSpec with ClusterTestKit {
     "be allowed to join a cluster when its configuration is incompatible but it's configured to NOT enforce it" taggedAs
     LongRunningTest in {
       // this config is NOT compatible with the cluster config,
-      // but node will ignore the the config check and join anyway
+      // but node will ignore the config check and join anyway
       val joinNodeConfig =
         ConfigFactory.parseString("""
             pekko.cluster {
@@ -523,7 +523,7 @@ class JoinConfigCompatCheckerSpec extends PekkoSpec with ClusterTestKit {
     "be allowed to re-join a cluster when its configuration is incompatible but it's configured to NOT enforce it" taggedAs
     LongRunningTest in {
       // this config is NOT compatible with the cluster config,
-      // but node will ignore the the config check and join anyway
+      // but node will ignore the config check and join anyway
       val joinNodeConfig =
         ConfigFactory.parseString("""
             pekko.cluster {
diff --git a/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala b/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala
index 471fb7f8a57..14d5198a6b7 100644
--- a/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala
+++ b/cluster/src/test/scala/org/apache/pekko/cluster/ReachabilityPerfSpec.scala
@@ -92,7 +92,7 @@ class ReachabilityPerfSpec extends AnyWordSpec with Matchers {
 
   private def recordsFrom(r1: Reachability): Unit = {
     r1.allObservers.foreach { o =>
-      r1.recordsFrom(o) should not be be(null)
+      r1.recordsFrom(o) should not be null
     }
   }
 
diff --git a/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala b/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala
index 73a9115c27f..75f22052309 100644
--- a/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala
+++ b/discovery/src/test/scala/org/apache/pekko/discovery/dns/DnsDiscoverySpec.scala
@@ -115,7 +115,7 @@ class DnsDiscoverySpec extends DockerBindDnsService(DnsDiscoverySpec.config) {
     }
 
     "be using its own resolver" in {
-      // future will fail if it it doesn't exist
+      // future will fail if it doesn't exist
       system.actorSelection("/system/SD-DNS/async-dns").resolveOne(2.seconds).futureValue
     }
 
diff --git a/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala b/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala
index f9f3f996dab..37f622c2ce5 100644
--- a/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala
+++ b/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala
@@ -1101,7 +1101,7 @@ object Replicator {
  *
  * For good introduction to the CRDT subject watch the
  * <a href="https://www.infoq.com/presentations/CRDT/">Eventually Consistent Data Structures</a>
- * talk by Sean Cribbs and and the
+ * talk by Sean Cribbs and the
  * <a href="https://www.microsoft.com/en-us/research/video/strong-eventual-consistency-and-conflict-free-replicated-data-types/">talk by Mark Shapiro</a>
  * and read the excellent paper <a href="https://hal.inria.fr/file/index/docid/555588/filename/techreport.pdf">
  * A comprehensive study of Convergent and Commutative Replicated Data Types</a>
diff --git a/docs/src/main/paradox/discovery/index.md b/docs/src/main/paradox/discovery/index.md
index 96653141742..fda23ccbdcc 100644
--- a/docs/src/main/paradox/discovery/index.md
+++ b/docs/src/main/paradox/discovery/index.md
@@ -74,7 +74,7 @@ Pekko Discovery with DNS does always use the @ref[Pekko-native "async-dns" imple
 DNS discovery maps `Lookup` queries as follows:
 
 * `serviceName`, `portName` and `protocol` set: SRV query in the form: `_port._protocol.name` Where the `_`s are added.
-* Any query  missing any of the fields is mapped to a A/AAAA query for the `serviceName`
+* Any query missing any of the fields is mapped to a A/AAAA query for the `serviceName`
 
 The mapping between Pekko service discovery terminology and SRV terminology:
 
diff --git a/docs/src/main/paradox/serialization-jackson.md b/docs/src/main/paradox/serialization-jackson.md
index 108a7530439..b5d8fa5271c 100644
--- a/docs/src/main/paradox/serialization-jackson.md
+++ b/docs/src/main/paradox/serialization-jackson.md
@@ -18,7 +18,7 @@ To use Jackson Serialization, you must add the following dependency in your proj
 
 ## Introduction
 
-You find general concepts for for Pekko serialization in the @ref:[Serialization](serialization.md) section.
+You find general concepts for Pekko serialization in the @ref:[Serialization](serialization.md) section.
 This section describes how to use the Jackson serializer for application specific messages and persistent
 events and snapshots.
 
diff --git a/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md b/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md
index 29951f9ed66..b2650a8c6c1 100644
--- a/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md
+++ b/docs/src/main/paradox/stream/operators/Source-or-Flow/alsoToAll.md
@@ -24,7 +24,7 @@ will also be sent to all those @apidoc[Sink]s.
 
 **completes** when upstream completes
 
-**cancels** when downstream or or any of the @apidoc[Sink]s cancels
+**cancels** when downstream or any of the @apidoc[Sink]s cancels
 
 @@@
 
diff --git a/docs/src/main/paradox/stream/stream-refs.md b/docs/src/main/paradox/stream/stream-refs.md
index 40d5f5e0196..1f3e5d795c9 100644
--- a/docs/src/main/paradox/stream/stream-refs.md
+++ b/docs/src/main/paradox/stream/stream-refs.md
@@ -158,7 +158,7 @@ Stream refs utilise normal actor messaging for their transport, and therefore pr
 
 - messages are sent over actor remoting
     - which relies on TCP (classic remoting or Artery TCP) or Aeron UDP for basic redelivery mechanisms
-- messages are guaranteed to to be in-order
+- messages are guaranteed to be in-order
 - messages can be lost, however:
     - a *dropped demand signal* will be re-delivered automatically (similar to system messages)
     - a *dropped element signal* will cause the stream to *fail*
diff --git a/docs/src/main/paradox/typed/cluster-sharding.md b/docs/src/main/paradox/typed/cluster-sharding.md
index 7a442e1cefd..1192a2ce5e7 100644
--- a/docs/src/main/paradox/typed/cluster-sharding.md
+++ b/docs/src/main/paradox/typed/cluster-sharding.md
@@ -776,7 +776,7 @@ Reasons for how this can happen:
 A lease can be a final backup that means that each shard won't create child entity actors unless it has the lease. 
 
 To use a lease for sharding set `pekko.cluster.sharding.use-lease` to the configuration location
-of the lease to use. Each shard will try and acquire a lease with with the name `<actor system name>-shard-<type name>-<shard id>` and
+of the lease to use. Each shard will try and acquire a lease with the name `<actor system name>-shard-<type name>-<shard id>` and
 the owner is set to the `Cluster(system).selfAddress.hostPort`.
 
 If a shard can't acquire a lease it will remain uninitialized so messages for entities it owns will
diff --git a/docs/src/main/paradox/typed/cluster-singleton.md b/docs/src/main/paradox/typed/cluster-singleton.md
index c705ad94034..e6c482d313d 100644
--- a/docs/src/main/paradox/typed/cluster-singleton.md
+++ b/docs/src/main/paradox/typed/cluster-singleton.md
@@ -38,7 +38,7 @@ instance will eventually be started.
 @@@ warning
 
 Make sure to not use a Cluster downing strategy that may split the cluster into several separate clusters in
-case of network problems or system overload (long GC pauses), since that will result in in *multiple Singletons*
+case of network problems or system overload (long GC pauses), since that will result in *multiple Singletons*
 being started, one in each separate cluster!
 See @ref:[Downing](cluster.md#downing).
 
@@ -106,7 +106,7 @@ This pattern may seem to be very tempting to use at first, but it has several dr
 @@@ warning
  
 Make sure to not use a Cluster downing strategy that may split the cluster into several separate clusters in
-case of network problems or system overload (long GC pauses), since that will result in in *multiple Singletons*
+case of network problems or system overload (long GC pauses), since that will result in *multiple Singletons*
 being started, one in each separate cluster!
 See @ref:[Downing](cluster.md#downing).
  
@@ -175,7 +175,7 @@ A lease can be a final backup that means that the singleton actor won't be creat
 the lease can be acquired. 
 
 To use a lease for singleton set `pekko.cluster.singleton.use-lease` to the configuration location
-of the lease to use. A lease with with the name `<actor system name>-singleton-<singleton actor path>` is used and
+of the lease to use. A lease with the name `<actor system name>-singleton-<singleton actor path>` is used and
 the owner is set to the @scala[`Cluster(system).selfAddress.hostPort`]@java[`Cluster.get(system).selfAddress().hostPort()`].
 
 If the cluster singleton manager can't acquire the lease it will keep retrying while it is the oldest node in the cluster.
diff --git a/docs/src/main/paradox/typed/distributed-data.md b/docs/src/main/paradox/typed/distributed-data.md
index 84a4104bad8..b87ee838223 100644
--- a/docs/src/main/paradox/typed/distributed-data.md
+++ b/docs/src/main/paradox/typed/distributed-data.md
@@ -561,7 +561,7 @@ Note that the full state is occasionally also replicated for delta-CRDTs, for ex
 new nodes are added to the cluster or when deltas could not be propagated because
 of network partitions or similar problems.
 
-The the delta propagation can be disabled with configuration property:
+The delta propagation can be disabled with configuration property:
 
 ```
 pekko.cluster.distributed-data.delta-crdt.enabled=off
diff --git a/docs/src/main/paradox/typed/persistence-snapshot.md b/docs/src/main/paradox/typed/persistence-snapshot.md
index bfc2112d238..799a0932c8e 100644
--- a/docs/src/main/paradox/typed/persistence-snapshot.md
+++ b/docs/src/main/paradox/typed/persistence-snapshot.md
@@ -52,7 +52,7 @@ events. This can be useful if snapshot serialization format has changed in an in
 not be used when events have been deleted.
 
 In order to use snapshots, a default snapshot-store (`pekko.persistence.snapshot-store.plugin`) must be configured,
-or you can pick a snapshot store for for a specific `EventSourcedBehavior` by
+or you can pick a snapshot store for a specific `EventSourcedBehavior` by
 @scala[defining it with `withSnapshotPluginId` of the `EventSourcedBehavior`]@java[overriding `snapshotPluginId` in
 the `EventSourcedBehavior`].
 
diff --git a/docs/src/main/paradox/typed/persistence-testing.md b/docs/src/main/paradox/typed/persistence-testing.md
index 17ecd576f4b..17fe88475f9 100644
--- a/docs/src/main/paradox/typed/persistence-testing.md
+++ b/docs/src/main/paradox/typed/persistence-testing.md
@@ -59,7 +59,7 @@ Java
 `PersistenceProbeBehavior` does not require any configuration.  It therefore does not verify the serialization of commands, events, or state.
 If using this style, it is advised to independently test serialization for those classes.
 
-## Unit testing with the the ActorTestKit and EventSourcedBehaviorTestKit
+## Unit testing with the ActorTestKit and EventSourcedBehaviorTestKit
 
 **Note!** The `EventSourcedBehaviorTestKit` is a new feature: the API may have changes breaking source compatibility in future versions.
 
diff --git a/docs/src/main/paradox/typed/style-guide.md b/docs/src/main/paradox/typed/style-guide.md
index 0b90acf6c90..1a23d977286 100644
--- a/docs/src/main/paradox/typed/style-guide.md
+++ b/docs/src/main/paradox/typed/style-guide.md
@@ -45,7 +45,7 @@ A few differences to note:
 * There is no class in the functional style, but that is not strictly a requirement and sometimes it's
   convenient to use a class also with the functional style to reduce number of parameters in the methods.
 * Mutable state, such as the @scala[`var n`]@java[`int n`] is typically used in the object-oriented style.
-* In the functional style the state is is updated by returning a new behavior that holds the new immutable state,
+* In the functional style the state is updated by returning a new behavior that holds the new immutable state,
   the @scala[`n: Int`]@java[`final int n`] parameter of the `counter` method.
 * The object-oriented style must use a new instance of the initial `Behavior` for each spawned actor instance,
   since the state in `AbstractBehavior` instance must not be shared between actor instances.
diff --git a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala
index e97c1894b2f..0d6266bf381 100644
--- a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala
+++ b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/javadsl/PersistentFSMMigration.scala
@@ -32,7 +32,7 @@ object PersistentFSMMigration {
    * Create a snapshot adapter that will adapt snapshots created by a PersistentFSM into
    * the correct State type of a [[EventSourcedBehavior]]
    * @param adapt Takes in the state identifier, snapshot persisted by the PersistentFSM and the state timeout and
-   *              returns the `State` that should be given to the the [[EventSourcedBehavior]]
+   *              returns the `State` that should be given to the [[EventSourcedBehavior]]
    * @tparam State State type of the [[EventSourcedBehavior]]
    * @return A [[SnapshotAdapter]] to be used with a [[EventSourcedBehavior]]
    */
diff --git a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala
index dda90f75e26..1cbf6197010 100644
--- a/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala
+++ b/persistence-typed/src/main/scala/org/apache/pekko/persistence/typed/scaladsl/PersistentFSMMigration.scala
@@ -28,7 +28,7 @@ object PersistentFSMMigration {
    * Create a snapshot adapter that will adapt snapshots created by a PersistentFSM into
    * the correct State type of a [[EventSourcedBehavior]]
    * @param adapt Takes in the state identifier, snapshot persisted by the PersistentFSM and the state timeout and
-   *              returns the `State` that should be given to the the [[EventSourcedBehavior]]
+   *              returns the `State` that should be given to the [[EventSourcedBehavior]]
    * @tparam State State type of the [[EventSourcedBehavior]]
    * @return A [[SnapshotAdapter]] to be used with a [[EventSourcedBehavior]]
    */
diff --git a/remote/src/main/resources/reference.conf b/remote/src/main/resources/reference.conf
index 2741292ad9e..b4bf9bac8e1 100644
--- a/remote/src/main/resources/reference.conf
+++ b/remote/src/main/resources/reference.conf
@@ -1235,7 +1235,7 @@ pekko {
         # at least one common subject name (CN or SAN).
         # The Key setup this implementation supports has some limitations:
         #   1. the private key must be provided on a PKCS#1 or a non-encrypted PKCS#8 PEM-formatted file
-        #   2. the private key must be be of an algorithm supported by `pekko-pki` tools (e.g. "RSA", not "EC")
+        #   2. the private key must be of an algorithm supported by `pekko-pki` tools (e.g. "RSA", not "EC")
         #   3. the node certificate must be issued by a root CA (not an intermediate CA)
         #   4. both the node and the CA certificates must be provided in PEM-formatted files
         rotating-keys-engine {
diff --git a/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala b/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala
index 85ccf11ccfb..7c3aac20308 100644
--- a/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala
+++ b/serialization-jackson/src/main/scala/org/apache/pekko/serialization/jackson/JacksonSerializer.scala
@@ -175,7 +175,7 @@ import pekko.util.OptionVal
  * Configuration in `pekko.serialization.jackson` section.
  * It will load Jackson modules defined in configuration `jackson-modules`.
  *
- * It will compress the payload if the compression `algorithm` is enabled and the the
+ * It will compress the payload if the compression `algorithm` is enabled and the
  * payload is larger than the configured `compress-larger-than` value.
  */
 @InternalApi private[pekko] abstract class JacksonSerializer(
diff --git a/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala b/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala
index 1fc675f6d9e..01c15ce4d83 100644
--- a/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala
+++ b/serialization-jackson3/src/main/scala/org/apache/pekko/serialization/jackson3/JacksonSerializer.scala
@@ -175,7 +175,7 @@ import pekko.util.OptionVal
  * Configuration in `pekko.serialization.jackson` section.
  * It will load Jackson modules defined in configuration `jackson-modules`.
  *
- * It will compress the payload if the compression `algorithm` is enabled and the the
+ * It will compress the payload if the compression `algorithm` is enabled and the
  * payload is larger than the configured `compress-larger-than` value.
  */
 @InternalApi private[pekko] abstract class JacksonSerializer(
diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala
index c9d8be38d9b..159b5c16111 100644
--- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala
+++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala
@@ -207,7 +207,7 @@ class GraphUnzipWithSpec extends StreamSpec("""
       rightProbe.expectNoMessage(100.millis)
     }
 
-    "propagagate last downstream cancellation cause once all downstreams have cancelled" in {
+    "propagate last downstream cancellation cause once all downstreams have cancelled" in {
       val probe = TestProbe()
       RunnableGraph
         .fromGraph(GraphDSL.create() { implicit b =>
diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala
index 802cd438e98..726f9d382c3 100644
--- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala
+++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/RestartSpec.scala
@@ -176,7 +176,7 @@ class RestartSpec
       probe.requestNext("a")
       probe.requestNext("b")
       probe.request(1)
-      // The probe should now be backing off again with with increased backoff
+      // The probe should now be backing off again with increased backoff
 
       // Now wait for the delay to pass, then it will start the new source, we also want to wait for the
       // subsequent backoff to pass, so it resets the restart count
@@ -314,7 +314,7 @@ class RestartSpec
       probe.requestNext("a")
       // There should be minBackoff delay
       probe.requestNext("a")
-      // The probe should now be backing off again with with increased backoff
+      // The probe should now be backing off again with increased backoff
 
       // Now wait for the delay to pass, then it will start the new source, we also want to wait for the
       // subsequent backoff to pass
diff --git a/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala b/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala
index e353d09fd83..c833e4fc27c 100644
--- a/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala
+++ b/testkit/src/test/scala/org/apache/pekko/testkit/PekkoSpecSpec.scala
@@ -46,7 +46,7 @@ class PekkoSpecSpec extends AnyWordSpec with Matchers {
     }
 
     "terminate all actors" in {
-      // verbose config just for demonstration purposes, please leave in in case of debugging
+      // verbose config just for demonstration purposes, please leave in case of debugging
       import scala.jdk.CollectionConverters._
       val conf = Map(
         "pekko.actor.debug.lifecycle" -> true,