diff --git a/akka-projection-grpc-tests/src/test/scala/akka/projection/grpc/internal/EventProducerServiceSpec.scala b/akka-projection-grpc-tests/src/test/scala/akka/projection/grpc/internal/EventProducerServiceSpec.scala
index f561484f6..225dbe8e9 100644
--- a/akka-projection-grpc-tests/src/test/scala/akka/projection/grpc/internal/EventProducerServiceSpec.scala
+++ b/akka-projection-grpc-tests/src/test/scala/akka/projection/grpc/internal/EventProducerServiceSpec.scala
@@ -613,14 +613,14 @@ class EventProducerServiceSpec
       protoAnySerialization.deserialize(out1.getEvent.metadata.get) shouldBe ReplicatedEventMetadata(
         originReplica = ReplicaId.empty,
         originSequenceNr = env1.sequenceNr,
-        version = VersionVector(env1.persistenceId, env1.sequenceNr),
+        version = VersionVector(ReplicaId.empty.id, env1.sequenceNr),
         concurrent = false)
 
       val out2 = probe.expectNext()
       protoAnySerialization.deserialize(out2.getEvent.metadata.get) shouldBe ReplicatedEventMetadata(
         originReplica = ReplicaId.empty,
         originSequenceNr = env2.sequenceNr,
-        version = VersionVector(env2.persistenceId, env2.sequenceNr),
+        version = VersionVector(ReplicaId.empty.id, env2.sequenceNr),
         concurrent = false)
     }