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 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();