root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 6 Packages Projects Releases Wiki Activity

HOTFIX: RegexSourceIntegrationTest needs to cleanup shared output topic (#5008) 

Reviewers: Guozhang Wang <wangguoz@gmail.com>
This commit is contained in:
Matthias J. Sax 2018-05-11 13:53:27 -07:00 committed by Guozhang Wang
parent caca1fdc90
commit adeced2997
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java
View File

@ -111,7 +111,9 @@ public class RegexSourceIntegrationTest {
} }
@Before @Before
public void setUp() { public void setUp() throws Exception {
CLUSTER.deleteAndRecreateTopics(DEFAULT_OUTPUT_TOPIC);
final Properties properties = new Properties(); final Properties properties = new Properties();
properties.put(IntegrationTestUtils.INTERNAL_LEAVE_GROUP_ON_CLOSE, true); properties.put(IntegrationTestUtils.INTERNAL_LEAVE_GROUP_ON_CLOSE, true);
streamsConfiguration = StreamsTestUtils.getStreamsConfig("regex-source-integration-test", streamsConfiguration = StreamsTestUtils.getStreamsConfig("regex-source-integration-test",