lhotari commented on code in PR #24790:
URL: https://github.com/apache/pulsar/pull/24790#discussion_r2384273242
##########
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java:
##########
@@ -1415,4 +1417,36 @@ InstrumentProvider instrumentProvider() {
public TransactionBuilder newTransaction() {
return new TransactionBuilderImpl(this, tcClient);
}
+
+ NameResolver<InetAddress> getNameResolver() {
+ return DnsResolverUtil.adaptToNameResolver(addressResolver);
+ }
+
+ /**
+ * Use reflection to extract Netty NameResolver from addressResolver
instance.
+ * @param addressResolver Netty AddressResolver instance
+ * @return Netty NameResolver instance
+ */
+ @SuppressWarnings("unchecked")
+ private NameResolver<InetAddress>
extractNameResolver(AddressResolver<InetSocketAddress> addressResolver) {
+ if (InetSocketAddressResolver.class.isInstance(addressResolver)) {
+ try {
+ Field nameResolverField =
+
FieldUtils.getDeclaredField(InetSocketAddressResolver.class, "nameResolver",
true);
+ if (nameResolverField != null) {
+ return (NameResolver<InetAddress>)
FieldUtils.readField(nameResolverField, addressResolver);
+ } else {
+ log.warn("Could not find nameResolver Field in
InetSocketAddressResolver");
+ }
+ } catch (Throwable t) {
+ log.warn("Failed to extract NameResolver from addressResolver.
DNS resolver won't be shared for HTTP "
+ + "client.", t);
+ }
+ } else {
+ log.warn("Cannot extract NameResolver from addressResolver
instance. DNS resolver won't be shared for HTTP "
+ + "client.");
+ }
+ // fallback to JDK default resolver
+ return new DefaultNameResolver(ImmediateEventExecutor.INSTANCE);
+ }
Review Comment:
This has already been removed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
