Explorar o código

Enabling synonyms for TopicConfig

Diego Ching %!s(int64=3) %!d(string=hai) anos
pai
achega
8a4df6b002

+ 2 - 1
kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/KafkaService.java

@@ -337,7 +337,8 @@ public class KafkaService {
         .map(topicName -> new ConfigResource(ConfigResource.Type.TOPIC, topicName))
         .map(topicName -> new ConfigResource(ConfigResource.Type.TOPIC, topicName))
         .collect(Collectors.toList());
         .collect(Collectors.toList());
 
 
-    return ClusterUtil.toMono(adminClient.describeConfigs(resources).all())
+    return ClusterUtil.toMono(adminClient.describeConfigs(resources,
+                    new DescribeConfigsOptions().includeSynonyms(true)).all())
         .map(configs ->
         .map(configs ->
             configs.entrySet().stream().collect(Collectors.toMap(
             configs.entrySet().stream().collect(Collectors.toMap(
                 c -> c.getKey().name(),
                 c -> c.getKey().name(),