diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java
index 770a3ae3dab..d03558666b9 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java
@@ -111,7 +111,9 @@ public class RegexSourceIntegrationTest {
     }
 
     @Before
-    public void setUp() {
+    public void setUp() throws Exception {
+        CLUSTER.deleteAndRecreateTopics(DEFAULT_OUTPUT_TOPIC);
+
         final Properties properties = new Properties();
         properties.put(IntegrationTestUtils.INTERNAL_LEAVE_GROUP_ON_CLOSE, true);
         streamsConfiguration = StreamsTestUtils.getStreamsConfig("regex-source-integration-test",