[KAFKA-2933] Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

• Type: Sub-task
• Status: Reopened
• Priority: Critical
• Resolution: Unresolved
• Affects Version/s: 0.10.0.0, 2.2.0
• Fix Version/s: 2.2.3
• Component/s: clients, consumer, core, unit tests
• Labels: flaky-test transient-unit-test-failure
• Assignee: Jason Gustafson
• Reporter: Guozhang Wang
• Created: 02/Dec/15 20:18
• Updated: 01/Aug/23 23:46

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

Issue Links

• is related to: KAFKA-8138 Flaky Test PlaintextConsumerTest#testFetchRecordLargerThanFetchMaxBytes
• is related to: KAFKA-3549 Close consumers instantiated in consumer tests