This is an automated email from the ASF dual-hosted git repository.
payang 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 45e5771c2b6 MINOR: Update
testAsyncConsumerWithConsumerProtocolDisabled to use group.version (#21658)
45e5771c2b6 is described below
commit 45e5771c2b66301c7fed01bf71c10bfbf12dc913
Author: PoAn Yang <[email protected]>
AuthorDate: Sun Mar 8 17:48:20 2026 +0900
MINOR: Update testAsyncConsumerWithConsumerProtocolDisabled to use
group.version (#21658)
[KIP-1237](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1237%3A+Deprecate+group.coordinator.rebalance.protocols+config)
deprecate `group.coordinator.rebalance.protocols` config. Update
`testAsyncConsumerWithConsumerProtocolDisabled` to reflect the change.
Reviewers: Christo Lolov <[email protected]>, TengYao Chi
<[email protected]>
Signed-off-by: PoAn Yang <[email protected]>
---
.../org/apache/kafka/clients/consumer/ConsumerIntegrationTest.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerIntegrationTest.java
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerIntegrationTest.java
index 0b0e65031f6..4fa3a63a379 100644
---
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerIntegrationTest.java
+++
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerIntegrationTest.java
@@ -34,11 +34,13 @@ import
org.apache.kafka.common.serialization.StringDeserializer;
import org.apache.kafka.common.serialization.StringSerializer;
import org.apache.kafka.common.test.ClusterInstance;
import org.apache.kafka.common.test.api.ClusterConfigProperty;
+import org.apache.kafka.common.test.api.ClusterFeature;
import org.apache.kafka.common.test.api.ClusterTest;
import org.apache.kafka.common.test.api.ClusterTests;
import org.apache.kafka.common.test.api.Type;
import org.apache.kafka.coordinator.group.GroupCoordinatorConfig;
import
org.apache.kafka.coordinator.group.metrics.GroupCoordinatorRuntimeMetrics;
+import org.apache.kafka.server.common.Feature;
import org.apache.kafka.test.TestUtils;
import java.nio.charset.StandardCharsets;
@@ -59,8 +61,9 @@ public class ConsumerIntegrationTest {
@ClusterTests({
@ClusterTest(serverProperties = {
@ClusterConfigProperty(key = "offsets.topic.num.partitions", value
= "1"),
- @ClusterConfigProperty(key = "offsets.topic.replication.factor",
value = "1"),
- @ClusterConfigProperty(key =
"group.coordinator.rebalance.protocols", value = "classic")
+ @ClusterConfigProperty(key = "offsets.topic.replication.factor",
value = "1")
+ }, features = {
+ @ClusterFeature(feature = Feature.GROUP_VERSION, version = 0)
})
})
public void testAsyncConsumerWithConsumerProtocolDisabled(ClusterInstance
clusterInstance) throws Exception {
