(kafka) branch trunk updated: KAFKA-17303 Enable testPutControllersInBootstrapBrokersConfig (#16838)

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chia7712 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 fac8cae3888 KAFKA-17303 Enable testPutControllersInBootstrapBrokersConfig (#16838)
fac8cae3888 is described below

commit fac8cae3888f0e8ee9fa2a863d80714c2173969f
Author: Dmitry Werner <gr...@gmail.com>
AuthorDate: Tue Aug 13 05:38:49 2024 +0500

    KAFKA-17303 Enable testPutControllersInBootstrapBrokersConfig (#16838)
    
    Reviewers: Chia-Ping Tsai <ch...@gmail.com>
---
 .../kafka/test/server/BootstrapControllersIntegrationTest.java    | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/core/src/test/java/kafka/test/server/BootstrapControllersIntegrationTest.java b/core/src/test/java/kafka/test/server/BootstrapControllersIntegrationTest.java
index c68e572fc95..097e0450f09 100644
--- a/core/src/test/java/kafka/test/server/BootstrapControllersIntegrationTest.java
+++ b/core/src/test/java/kafka/test/server/BootstrapControllersIntegrationTest.java
@@ -41,10 +41,10 @@ import org.apache.kafka.common.config.ConfigResource;
 import org.apache.kafka.common.errors.InvalidUpdateVersionException;
 import org.apache.kafka.common.errors.MismatchedEndpointTypeException;
 import org.apache.kafka.common.errors.UnsupportedEndpointTypeException;
+import org.apache.kafka.common.errors.UnsupportedVersionException;
 import org.apache.kafka.server.common.MetadataVersion;
 import org.apache.kafka.test.TestUtils;
 
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.ExtendWith;
 
@@ -87,7 +87,6 @@ public class BootstrapControllersIntegrationTest {
         }
     }
 
-    @Disabled
     @ClusterTest
     public void testPutControllersInBootstrapBrokersConfig(ClusterInstance clusterInstance) {
         Map<String, Object> config = Collections.singletonMap(BOOTSTRAP_SERVERS_CONFIG, clusterInstance.bootstrapControllers());
@@ -95,9 +94,8 @@ public class BootstrapControllersIntegrationTest {
             ExecutionException exception = assertThrows(ExecutionException.class,
                     () -> admin.describeCluster().clusterId().get(1, TimeUnit.MINUTES));
             assertNotNull(exception.getCause());
-            assertEquals(MismatchedEndpointTypeException.class, exception.getCause().getClass());
-            assertEquals("This endpoint does not appear to be a BROKER.",
-                    exception.getCause().getMessage());
+            assertEquals(UnsupportedVersionException.class, exception.getCause().getClass());
+            assertEquals("The node does not support METADATA", exception.getCause().getMessage());
         }
     }