[kafka] branch trunk updated: HOTFIX: RegexSourceIntegrationTest needs to cleanup shared output topic (#5008)

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new adeced2  HOTFIX: RegexSourceIntegrationTest needs to cleanup shared output topic (#5008)
adeced2 is described below

commit adeced299785bbeab53241e0013a1f22cdeae76f
Author: Matthias J. Sax <mj...@apache.org>
AuthorDate: Fri May 11 13:53:27 2018 -0700

    HOTFIX: RegexSourceIntegrationTest needs to cleanup shared output topic (#5008)
    
    Reviewers: Guozhang Wang <wa...@gmail.com>
---
 .../apache/kafka/streams/integration/RegexSourceIntegrationTest.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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 770a3ae..d035586 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",

-- 
To stop receiving notification emails like this one, please contact
guozhang@apache.org.