[KAFKA-13514] Flaky test StickyAssignorTest

• Type: Test
• Status: Open
• Priority: Critical
• Resolution: Unresolved
• Component/s: clients, consumer, unit tests
• Labels: flaky-test
• Assignee: Luke Chen
• Reporter: Matthias J. Sax
• Created: 07/Dec/21 18:06
• Updated: 01/Aug/23 23:46

Description

org.apache.kafka.clients.consumer.StickyAssignorTest.testLargeAssignmentAndGroupWithNonEqualSubscription()

No real stack trace, but only:

java.util.concurrent.TimeoutException: testLargeAssignmentAndGroupWithNonEqualSubscription() timed out after 60 seconds

STDOUT

[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)

Issue Links

• is related to: KAFKA-12676 Improve sticky general assignor underlying algorithm for the unequal subscriptions case
• links to: GitHub Pull Request #11578