MINOR: Added test for ClusterConfig#displayTags (apache#16110)

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
apourchet · Jun 6, 2024 · f36a873 · f36a873
1 parent 226f3c5
commit f36a873
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/core/src/test/java/kafka/test/ClusterConfigTest.java b/core/src/test/java/kafka/test/ClusterConfigTest.java
@@ -29,6 +29,8 @@
 import java.lang.reflect.Field;
 import java.util.Arrays;
 import java.util.Collections;
+import java.util.List;
+import java.util.Set;
 import java.util.Map;
 import java.util.stream.Collectors;
 
@@ -96,4 +98,18 @@ public void testDisksPerBrokerIsZero() {
                 .setDisksPerBroker(0)
                 .build());
     }
+
+    @Test
+    public void testDisplayTags() {
+        List<String> tags = Arrays.asList("tag 1", "tag 2", "tag 3");
+        ClusterConfig clusterConfig = ClusterConfig.defaultBuilder().setTags(tags).build();
+
+        Set<String> expectedDisplayTags = clusterConfig.displayTags();
+
+        Assertions.assertTrue(expectedDisplayTags.contains("tag 1"));
+        Assertions.assertTrue(expectedDisplayTags.contains("tag 2"));
+        Assertions.assertTrue(expectedDisplayTags.contains("tag 3"));
+        Assertions.assertTrue(expectedDisplayTags.contains("MetadataVersion=" + MetadataVersion.latestTesting()));
+        Assertions.assertTrue(expectedDisplayTags.contains("Security=" + SecurityProtocol.PLAINTEXT));
+    }
 }