[ https://issues.apache.org/jira/browse/KAFKA-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832202#comment-16832202 ]
Vahid Hashemian commented on KAFKA-2933: ---------------------------------------- Removed Fix Version 2.2.1 as this issue is not blocking that release. > Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment > ----------------------------------------------------------------------------- > > Key: KAFKA-2933 > URL: https://issues.apache.org/jira/browse/KAFKA-2933 > Project: Kafka > Issue Type: Sub-task > Components: clients, core, unit tests > Affects Versions: 0.10.0.0, 2.2.0 > Reporter: Guozhang Wang > Assignee: Jason Gustafson > Priority: Critical > Labels: flaky-test, transient-unit-test-failure > Fix For: 2.3.0, 2.2.2 > > > {code} > 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 > {code} > Example: https://builds.apache.org/job/kafka-trunk-git-pr-jdk7/1582/console -- This message was sent by Atlassian JIRA (v7.6.3#76005)