diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaRequestHandler.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaRequestHandler.java
index 3d0b78c5d0..d160e829e3 100644
--- a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaRequestHandler.java
+++ b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/KafkaRequestHandler.java
@@ -663,7 +663,7 @@ protected void handleTopicMetadataRequest(KafkaHeaderAndRequest metadataHar,
         // This map is used to find the original topic name. Both key and value don't have the "-partition-" suffix.
         final Map<String, String> fullTopicNameToOriginal = (request.topics() == null)
                 ? Collections.emptyMap()
-                : request.topics().stream().collect(
+                : request.topics().stream().distinct().collect(
                         Collectors.toMap(
                                 topic -> new KopTopic(topic, namespacePrefix).getFullName(),
                                 topic -> topic