diff --git a/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java b/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java
index 2e6fd0ee51..4235fa9f82 100644
--- a/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java
+++ b/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java
@@ -97,7 +97,6 @@ public class ReactiveRedisStreamMessageProducerTests extends RedisAvailableTests
 	@After
 	public void tearDown() {
 		this.reactiveRedisStreamProducer.stop();
-		RedisAvailableRule.connectionFactory.resetConnection();
 	}
 
 	@Test