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:
Yes, it fails on trunk.
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]
