diff --git a/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/ReactiveTransactionIntegrationTests.java b/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/ReactiveTransactionIntegrationTests.java
index f4d918f31..88157024b 100644
--- a/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/ReactiveTransactionIntegrationTests.java
+++ b/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/ReactiveTransactionIntegrationTests.java
@@ -453,7 +453,7 @@ public class ReactiveTransactionIntegrationTests {
 			TransactionalOperator transactionalOperator = TransactionalOperator.create(manager,
 					new DefaultTransactionDefinition());
 
-			return Flux.merge(operations.save(new EventLog(new ObjectId(), "beforeConvert")), //
+			return Flux.concat(operations.save(new EventLog(new ObjectId(), "beforeConvert")), //
 					operations.save(new EventLog(new ObjectId(), "afterConvert")), //
 					operations.save(new EventLog(new ObjectId(), "beforeInsert")), //
 					operations.save(person), //