chore: More detailed error message for invalid replica config

akka · Nov 9, 2023 · b155052 · b155052
1 parent 0e185c8
commit b155052
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...ction-grpc/src/main/scala/akka/projection/grpc/replication/internal/ReplicationImpl.scala b/...ction-grpc/src/main/scala/akka/projection/grpc/replication/internal/ReplicationImpl.scala
@@ -173,7 +173,11 @@ private[akka] object ReplicationImpl {
                   envelope.eventMetadata match {
                     case Some(replicatedEventMetadata: ReplicatedEventMetadata) =>
                       // skipping events originating from other replicas is handled by filtering but for good measure
-                      require(replicatedEventMetadata.originReplica == remoteReplica.replicaId)
+                      if (replicatedEventMetadata.originReplica != remoteReplica.replicaId)
+                        throw new IllegalArgumentException(
+                          "Expected replicated event from replica " +
+                          s"[${remoteReplica.replicaId}] but was [${replicatedEventMetadata.originReplica}]. " +
+                          "Verify your replication configuration, such as self-replica-id.")
 
                       val replicationId = ReplicationId.fromString(envelope.persistenceId)
                       val destinationReplicaId = replicationId.withReplica(settings.selfReplicaId)