avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412178952
##########
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java
##########
@@ -179,6 +179,44 @@ public void subscribe(final Pattern topics, final
ConsumerRebalanceListener list
TestUtils.waitForCondition(() ->
assignedTopics.equals(expectedSecondAssignment), STREAM_TASKS_NOT_UPDATED);
+ CLUSTER.deleteTopicsAndWait("TEST-TOPIC-1", "TEST-TOPIC-2");
+ }
+
+ @Test
+ public void testRegexRecordsAreProcessedAfterReassignment() throws
Exception {
Review comment:
I found reason: here I tried to isolate tests: so we can create same
topic in one test, delete it after we are done, do the same in next test, so
on. But after each test it calls `streams.close()` in `teardown` method. I
guess It tries to do smth with removed topics and gets `TimeoutException`
because can't do it. may be it's issue but probably it happens only when close.
But it seems to be not related to this task. @abbccdda What do you think? I
fixed it easily (may be not best approach): call `streams.close` in test method
body before deleting topics.
----------------------------------------------------------------
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:
[email protected]
