From b155956d3dc1f0e691ae94feb84dba652d5ab7cd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=8D=A2=E6=98=A5=E4=BA=AE?= <946240095@qq.com>
Date: Sun, 26 Jan 2025 22:12:30 +0800
Subject: [PATCH] [INLONG-11711][SDK] SortSDK shares the same PulsarClient
 among different SortTasks to avoid performance bottlenecks caused by too many
 PulsarClients

---
 .../apache/inlong/sdk/sort/manager/InlongMultiTopicManager.java  | 1 -
 .../apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java | 1 -
 .../org/apache/inlong/sdk/sort/manager/InlongTopicManager.java   | 1 -
 3 files changed, 3 deletions(-)

diff --git a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongMultiTopicManager.java b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongMultiTopicManager.java
index 8100ebd5e3..2d098345ca 100644
--- a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongMultiTopicManager.java
+++ b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongMultiTopicManager.java
@@ -220,7 +220,6 @@ private void updatePulsarFetcher(String clusterId, List<InLongTopic> topics) {
                     auth = AuthenticationFactory.token(token);
                 }
                 PulsarClient pulsarClient = PulsarClient.builder()
-                        .useNoopDnsResolver(true)
                         .serviceUrl(topic.getInLongCluster().getBootstraps())
                         .authentication(auth)
                         .build();
diff --git a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java
index 195261eaa4..8ced073b47 100644
--- a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java
+++ b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java
@@ -370,7 +370,6 @@ private boolean checkAndCreateNewPulsarClient(InLongTopic topic) {
                         auth = AuthenticationFactory.token(token);
                     }
                     PulsarClient pulsarClient = PulsarClient.builder()
-                            .useNoopDnsResolver(true)
                             .serviceUrl(topic.getInLongCluster().getBootstraps())
                             .authentication(auth)
                             .build();
diff --git a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongTopicManager.java b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongTopicManager.java
index 32ac9453ad..378d8deb3c 100644
--- a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongTopicManager.java
+++ b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongTopicManager.java
@@ -375,7 +375,6 @@ private void createPulsarClient(CacheZoneCluster cluster) {
                 auth = AuthenticationFactory.token(token);
             }
             PulsarClient pulsarClient = PulsarClient.builder()
-                    .useNoopDnsResolver(true)
                     .serviceUrl(cluster.getBootstraps())
                     .authentication(auth)
                     .build();