Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2054 Fix Kafka transient unit test failures
  3. KAFKA-2933

Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

    XMLWordPrintableJSON

    Details

      Description

      kafka.api.PlaintextConsumerTest > testMultiConsumerDefaultAssignment FAILED
          java.lang.AssertionError: Did not get valid assignment for partitions [topic1-2, topic2-0, topic1-4, topic-1, topic-0, topic2-1, topic1-0, topic1-3, topic1-1, topic2-2] after we changed subscription
              at org.junit.Assert.fail(Assert.java:88)
              at kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:747)
              at kafka.api.PlaintextConsumerTest.validateGroupAssignment(PlaintextConsumerTest.scala:644)
              at kafka.api.PlaintextConsumerTest.changeConsumerGroupSubscriptionAndValidateAssignment(PlaintextConsumerTest.scala:663)
              at kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment(PlaintextConsumerTest.scala:461)
      
          java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access
      

      Example: https://builds.apache.org/job/kafka-trunk-git-pr-jdk7/1582/console

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                hachikuji Jason Gustafson
                Reporter:
                guozhang Guozhang Wang
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated: