optimize topic pattern subscriber

apache · Sep 4, 2024 · e2b706f · e2b706f
1 parent dec4812
commit e2b706f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...a/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java b/...a/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java
@@ -44,7 +44,7 @@ static Map<String, TopicDescription> getTopicMetadata(AdminClient adminClient, P
         try {
             Set<String> allTopicNames = adminClient.listTopics().names().get();
             Set<String> patternTopicNames = allTopicNames.stream()
-                    .filter(topicName -> topicPattern.matcher(topicName).matches())
+                    .filter(name -> topicPattern.matcher(name).matches())
                     .collect(Collectors.toSet());
             return getTopicMetadata(adminClient, patternTopicNames);
         } catch (Exception e) {