diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/util/ClusterUtil.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/util/ClusterUtil.java index 7abd4b64dd..889079eaef 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/util/ClusterUtil.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/util/ClusterUtil.java @@ -139,7 +139,9 @@ public class ClusterUtil { public static InternalTopic mapToInternalTopic(TopicDescription topicDescription) { var topic = InternalTopic.builder(); - topic.internal(topicDescription.isInternal()); + topic.internal( + topicDescription.isInternal() || topicDescription.name().startsWith("_") + ); topic.name(topicDescription.name()); List partitions = topicDescription.partitions().stream().map(