Guozhang Wang created KAFKA-2933:
------------------------------------
Summary: Failure in
kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment
Key: KAFKA-2933
URL: https://issues.apache.org/jira/browse/KAFKA-2933
Project: Kafka
Issue Type: Sub-task
Affects Versions: 0.9.1.0
Reporter: Guozhang Wang
{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
(v6.3.4#6332)
