From b72df9b8e95b4312e8f073603beb22a0b07b3bab Mon Sep 17 00:00:00 2001 From: Enrico Olivelli Date: Tue, 1 Mar 2022 16:26:21 +0100 Subject: [PATCH] Handle duplicate topic names requests in MetadataRequest --- .../streamnative/pulsar/handlers/kop/KafkaRequestHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 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