diff --git a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/internal/EventSourcedBehaviorTestKitImpl.scala b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/internal/EventSourcedBehaviorTestKitImpl.scala
index 12902ee9d8..02bea0a62d 100644
--- a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/internal/EventSourcedBehaviorTestKitImpl.scala
+++ b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/internal/EventSourcedBehaviorTestKitImpl.scala
@@ -81,6 +81,7 @@ import akka.persistence.typed.internal.EventSourcedBehaviorImpl
   private def system: ActorSystem[_] = actorTestKit.system
 
   override val persistenceTestKit: PersistenceTestKit = PersistenceTestKit(system)
+  persistenceTestKit.clearAll()
 
   private val probe = actorTestKit.createTestProbe[Any]()
   private val stateProbe = actorTestKit.createTestProbe[State]()
@@ -99,8 +100,6 @@ import akka.persistence.typed.internal.EventSourcedBehaviorImpl
 
   private var emptyStateVerified = false
 
-  persistenceTestKit.clearByPersistenceId(persistenceId.id)
-
   override def runCommand(command: Command): CommandResult[Command, Event, State] = {
     if (serializationSettings.enabled && serializationSettings.verifyCommands)
       verifySerializationAndThrow(command, "Command")