[
https://issues.apache.org/jira/browse/KAFKA-13514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498386#comment-17498386
]
A. Sophie Blee-Goldman commented on KAFKA-13514:
------------------------------------------------
Hey [~showuon] just checking in since I saw this fail again, you're saying
there's a bug in the generalAssign case that's causing it to assign the same
partition to more than one consumer? If so, what's happening in this case – do
we actually catch this bug somewhere in the assignor or coordinator, or would
this actually result in the two consumers taking ownership of the same
partition at the same time?
If the latter, that's a pretty severe bug and we should absolutely be trying to
get a fix in possibly as a blocker for the next release (of course AFAICT the
general case where consumers have unequal subscriptions is extremely rare, but
it's still a correctness bug and thus critical).
Do you have any sense of whether this was a newly introduced bug or has it been
there since the sticky assignment algorithm was first written? I'm pretty sure
we haven't touched the general assignment algorithm so my guess it was always
there, and thus maybe not a blocker, but just wondering
> Flakey test StickyAssignorTest
> ------------------------------
>
> Key: KAFKA-13514
> URL: https://issues.apache.org/jira/browse/KAFKA-13514
> Project: Kafka
> Issue Type: Test
> Components: clients, unit tests
> Reporter: Matthias J. Sax
> Assignee: Luke Chen
> Priority: Critical
> Labels: flaky-test
>
> org.apache.kafka.clients.consumer.StickyAssignorTest.testLargeAssignmentAndGroupWithNonEqualSubscription()
> No real stack trace, but only:
> {quote}java.util.concurrent.TimeoutException:
> testLargeAssignmentAndGroupWithNonEqualSubscription() timed out after 60
> seconds{quote}
> STDOUT
> {quote}[2021-12-07 01:32:23,920] ERROR Found multiple consumers consumer1 and
> consumer2 claiming the same TopicPartition topic-0 in the same generation -1,
> this will be invalidated and removed from their previous assignment.
> (org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor:150)
> [2021-12-07 01:32:58,964] ERROR Found multiple consumers consumer1 and
> consumer2 claiming the same TopicPartition topic-0 in the same generation -1,
> this will be invalidated and removed from their previous assignment.
> (org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor:150)
> [2021-12-07 01:32:58,976] ERROR Found multiple consumers consumer1 and
> consumer2 claiming the same TopicPartition topic-0 in the same generation -1,
> this will be invalidated and removed from their previous assignment.
> (org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor:150){quote}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
