diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java index ee6df4e65a2e9..fe6b4d100ff2a 100644 --- a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java @@ -22,6 +22,7 @@ import org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignorTest.RackConfig; import org.apache.kafka.common.PartitionInfo; import org.apache.kafka.common.TopicPartition; +import org.apache.kafka.common.test.api.Flaky; import org.apache.kafka.common.utils.CollectionUtils; import org.apache.kafka.common.utils.Utils; @@ -741,6 +742,7 @@ public void testLargeAssignmentAndGroupWithUniformSubscription(boolean hasConsum assignor.assignPartitions(partitionsPerTopic, subscriptions); } + @Flaky("KAFKA-13514") @Timeout(90) @ParameterizedTest(name = TEST_NAME_WITH_CONSUMER_RACK) @ValueSource(booleans = {false, true})