dengziming commented on code in PR #12206:
URL: https://github.com/apache/kafka/pull/12206#discussion_r889424223
##
clients/src/main/java/org/apache/kafka/clients/admin/QuorumInfo.java:
##
@@ -0,0 +1,149 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mo
dengziming commented on code in PR #12206:
URL: https://github.com/apache/kafka/pull/12206#discussion_r889423970
##
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java:
##
@@ -4833,6 +4879,92 @@ public void testDescribeFeaturesFailure() {
}
dengziming commented on code in PR #12206:
URL: https://github.com/apache/kafka/pull/12206#discussion_r886641824
##
core/src/test/scala/integration/kafka/server/KRaftClusterTest.scala:
##
@@ -725,4 +725,35 @@ class KRaftClusterTest {
cluster.close()
}
}
+
+ @Test
dengziming commented on code in PR #12206:
URL: https://github.com/apache/kafka/pull/12206#discussion_r885406422
##
core/src/test/scala/integration/kafka/server/KRaftClusterTest.scala:
##
@@ -725,4 +725,35 @@ class KRaftClusterTest {
cluster.close()
}
}
+
+ @Test
dengziming commented on code in PR #12206:
URL: https://github.com/apache/kafka/pull/12206#discussion_r882483263
##
core/src/test/scala/integration/kafka/server/KRaftClusterTest.scala:
##
@@ -725,4 +725,34 @@ class KRaftClusterTest {
cluster.close()
}
}
+
+ @Test
dengziming commented on code in PR #12206:
URL: https://github.com/apache/kafka/pull/12206#discussion_r882261419
##
core/src/test/scala/unit/kafka/server/DescribeQuorumIntegrationTest.scala:
##
@@ -26,16 +25,17 @@ import org.apache.kafka.common.protocol.{ApiKeys, Errors}
import
