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 <[email protected]>
AuthorDate: Fri May 11 13:53:27 2018 -0700
HOTFIX: RegexSourceIntegrationTest needs to cleanup shared output topic
(#5008)
Reviewers: Guozhang Wang <[email protected]>
---
.../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
[email protected].
