Explorar o código

Fix topic internal indication (#2846)

Roman Zabaluev %!s(int64=2) %!d(string=hai) anos
pai
achega
2f2e19d1bc

+ 1 - 3
kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/InternalTopic.java

@@ -42,9 +42,7 @@ public class InternalTopic {
                                    Metrics metrics,
                                    InternalLogDirStats logDirInfo) {
     var topic = InternalTopic.builder();
-    topic.internal(
-        topicDescription.isInternal() || topicDescription.name().startsWith("_")
-    );
+    topic.internal(topicDescription.isInternal());
     topic.name(topicDescription.name());
 
     List<InternalPartition> partitions = topicDescription.partitions().stream()