[
https://issues.apache.org/jira/browse/KAFKA-10083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-10083:
------------------------------
Description:
[https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/815/]
h3. Error Message
java.lang.AssertionError
h3. Stacktrace
java.lang.AssertionError at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$PartitionMovements.getTheActualPartitionToBeMoved(AbstractStickyAssignor.java:836)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$PartitionMovements.access$100(AbstractStickyAssignor.java:780)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.reassignPartition(AbstractStickyAssignor.java:699)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.reassignPartition(AbstractStickyAssignor.java:689)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.performReassignments(AbstractStickyAssignor.java:661)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.balance(AbstractStickyAssignor.java:597)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.generalAssign(AbstractStickyAssignor.java:352)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.assign(AbstractStickyAssignor.java:85)
at
org.apache.kafka.clients.consumer.CooperativeStickyAssignor.assign(CooperativeStickyAssignor.java:64)
at
org.apache.kafka.clients.consumer.CooperativeStickyAssignorTest.verifyValidityAndBalance(CooperativeStickyAssignorTest.java:68)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignorTest.testReassignmentWithRandomSubscriptionsAndChanges(AbstractStickyAssignorTest.java:654)
was:
[https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/815/]
It can also locally reproduce this error.
h3. Error Message
java.lang.AssertionError
h3. Stacktrace
java.lang.AssertionError at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$PartitionMovements.getTheActualPartitionToBeMoved(AbstractStickyAssignor.java:836)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$PartitionMovements.access$100(AbstractStickyAssignor.java:780)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.reassignPartition(AbstractStickyAssignor.java:699)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.reassignPartition(AbstractStickyAssignor.java:689)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.performReassignments(AbstractStickyAssignor.java:661)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.balance(AbstractStickyAssignor.java:597)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.generalAssign(AbstractStickyAssignor.java:352)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.assign(AbstractStickyAssignor.java:85)
at
org.apache.kafka.clients.consumer.CooperativeStickyAssignor.assign(CooperativeStickyAssignor.java:64)
at
org.apache.kafka.clients.consumer.CooperativeStickyAssignorTest.verifyValidityAndBalance(CooperativeStickyAssignorTest.java:68)
at
org.apache.kafka.clients.consumer.internals.AbstractStickyAssignorTest.testReassignmentWithRandomSubscriptionsAndChanges(AbstractStickyAssignorTest.java:654)
> fix failed testReassignmentWithRandomSubscriptionsAndChanges
> ------------------------------------------------------------
>
> Key: KAFKA-10083
> URL: https://issues.apache.org/jira/browse/KAFKA-10083
> Project: Kafka
> Issue Type: Bug
> Reporter: Luke Chen
> Assignee: Luke Chen
> Priority: Major
>
> [https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/815/]
>
> h3. Error Message
> java.lang.AssertionError
> h3. Stacktrace
> java.lang.AssertionError at
> org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$PartitionMovements.getTheActualPartitionToBeMoved(AbstractStickyAssignor.java:836)
> at
> org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor$PartitionMovements.access$100(AbstractStickyAssignor.java:780)
> at
> org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.reassignPartition(AbstractStickyAssignor.java:699)
> at
> org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.reassignPartition(AbstractStickyAssignor.java:689)
> at
> org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.performReassignments(AbstractStickyAssignor.java:661)
> at
> org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.balance(AbstractStickyAssignor.java:597)
> at
> org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.generalAssign(AbstractStickyAssignor.java:352)
> at
> org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.assign(AbstractStickyAssignor.java:85)
> at
> org.apache.kafka.clients.consumer.CooperativeStickyAssignor.assign(CooperativeStickyAssignor.java:64)
> at
> org.apache.kafka.clients.consumer.CooperativeStickyAssignorTest.verifyValidityAndBalance(CooperativeStickyAssignorTest.java:68)
> at
> org.apache.kafka.clients.consumer.internals.AbstractStickyAssignorTest.testReassignmentWithRandomSubscriptionsAndChanges(AbstractStickyAssignorTest.java:654)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
