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 5614cfd8cd..2c5b8c6a2c 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
@@ -22,7 +22,6 @@ import static org.awaitility.Awaitility.await;
 import java.time.Duration;
 import java.util.concurrent.atomic.AtomicReference;
 
-import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -64,7 +63,7 @@ import reactor.test.StepVerifier;
  * @since 5.4
  */
 @RunWith(SpringRunner.class)
-@DirtiesContext
+@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
 public class ReactiveRedisStreamMessageProducerTests extends RedisAvailableTests {
 
 	private static final String STREAM_KEY = "myStream";
@@ -98,11 +97,6 @@ public class ReactiveRedisStreamMessageProducerTests extends RedisAvailableTests
 		this.template.delete(STREAM_KEY).block();
 	}
 
-	@After
-	public void tearDown() {
-		this.redisStreamMessageProducer.stop();
-	}
-
 	@Test
 	@RedisAvailable
 	public void testConsumerGroupCreation() {