Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-8011

Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

    XMLWordPrintableJSON

Details

    Description

      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. 

      Attachments

        1. streams_1_1_tests.png
          315 kB
          Bill Bejeck
        2. streams_1_0_test_results.png
          297 kB
          Bill Bejeck
        3. org.apache.kafka.streams.integration.RegexSourceIntegrationTest.html
          503 kB
          A. Sophie Blee-Goldman

        Activity

          People

            mjsax Matthias J. Sax
            bbejeck Bill Bejeck
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: