Bill Bejeck created KAFKA-8011:
----------------------------------

             Summary: Flaky Test RegexSourceIntegrationTest.
                 Key: KAFKA-8011
                 URL: https://issues.apache.org/jira/browse/KAFKA-8011
             Project: Kafka
          Issue Type: Improvement
          Components: streams
            Reporter: Bill Bejeck
            Assignee: Bill Bejeck


The RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

and RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted  tests use an 
ArrayList to assert the topics assigned to the Streams application. 

The ConsumerRebalanceListener used in the test operates on this list as does 
the TestUtils.waitForCondition() to verify the expected topic assignments.

Using the same list in both places can cause a ConcurrentModficationException 
if the rebalance listener modifies the assignment at the same time 
TestUtils.waitForCondition() is using the list to verify the expected topics. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to