This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 7c536c9643e Mark PlaintextAdminIntegrationTest#testShareGroups as
flaky (#17649)
7c536c9643e is described below
commit 7c536c9643ea43d5956e6ee97275f5b0dd9f4ec5
Author: David Arthur <[email protected]>
AuthorDate: Thu Oct 31 10:19:14 2024 -0400
Mark PlaintextAdminIntegrationTest#testShareGroups as flaky (#17649)
Reviewers: Andrew Schofield <[email protected]>, Ron Dagostino
<[email protected]>
---
.../scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
b/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
index d563886ac5b..2bda5003df8 100644
---
a/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
+++
b/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
@@ -44,6 +44,7 @@ import org.apache.kafka.common.quota.{ClientQuotaAlteration,
ClientQuotaEntity,
import org.apache.kafka.common.requests.DeleteRecordsRequest
import org.apache.kafka.common.resource.{PatternType, ResourcePattern,
ResourceType}
import org.apache.kafka.common.serialization.{ByteArrayDeserializer,
ByteArraySerializer}
+import org.apache.kafka.common.test.api.Flaky
import org.apache.kafka.common.utils.{Time, Utils}
import org.apache.kafka.common.{ConsumerGroupState, ElectionType, GroupType,
IsolationLevel, ShareGroupState, TopicCollection, TopicPartition,
TopicPartitionInfo, TopicPartitionReplica, Uuid}
import
org.apache.kafka.controller.ControllerRequestContextUtil.ANONYMOUS_CONTEXT
@@ -2087,6 +2088,7 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegrationTest {
}
}
+ @Flaky("KAFKA-17463")
@ParameterizedTest
@ValueSource(strings = Array("kraft+kip932"))
def testShareGroups(quorum: String): Unit = {
