cadonna commented on a change in pull request #9648: URL: https://github.com/apache/kafka/pull/9648#discussion_r529840078
########## File path: streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java ########## @@ -198,9 +200,16 @@ public void testRegexRecordsAreProcessedAfterReassignment() throws Exception { final StreamsBuilder builder = new StreamsBuilder(); final KStream<String, String> pattern1Stream = builder.stream(Pattern.compile("TEST-TOPIC-\\d")); - pattern1Stream.to(outputTopic, Produced.with(Serdes.String(), Serdes.String())); + final KStream<String, String> otherStream = builder.stream(Pattern.compile("not-a-match")); + + pattern1Stream + .selectKey((k, v) -> k) + .groupByKey() + .aggregate(() -> "", (k, v, a) -> v) + .toStream().to(outputTopic, Produced.with(Serdes.String(), Serdes.String())); Review comment: You would have a source node in one sub-topology an a source node in the other topology. I thought that was the pattern in the bug report, but I now realized that the bug report uses a pattern similar to the one you did specified. Wouldn't it make sense to test both? ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org