[INLONG-11711][SDK] SortSDK shares the same PulsarClient among differ…

…ent SortTasks to avoid performance bottlenecks caused by too many PulsarClients
luchunliang · Jan 26, 2025 · b155956 · b155956
1 parent 2c41162
commit b155956
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 3 deletions.
diff --git a/...dk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongMultiTopicManager.java b/...dk/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/...k/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java b/...k/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
@@ -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();