This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 2fbdb174718 [improve][broker] Support shrink for
ConcurrentSortedLongPairSet (#15354)
new 687911344a5 [Proxy & Client] Configure Netty DNS resolver to match JDK
DNS caching setting, share DNS resolver instance in Proxy (#15219)
new 5a94b19fdfd [Proxy] Fix proxy connection leak when inbound connection
closes while connecting is in progress (#15366)
new 278531f2f92 [Broker/Client] Close connection if a ping or pong message
cannot be sent (#15382)
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/pulsar/client/impl/ConnectionPool.java | 26 +++-
pulsar-common/pom.xml | 5 +
.../pulsar/common/protocol/PulsarHandler.java | 18 ++-
.../pulsar/common/util/netty/DnsResolverUtil.java | 75 +++++++++++
.../pulsar/proxy/server/DirectProxyHandler.java | 19 +--
.../pulsar/proxy/server/ProxyConnection.java | 139 +++++++++++++++------
.../pulsar/proxy/server/ProxyConnectionPool.java | 60 ---------
.../apache/pulsar/proxy/server/ProxyService.java | 3 +
.../proxy/server/ServiceChannelInitializer.java | 2 +-
9 files changed, 234 insertions(+), 113 deletions(-)
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/netty/DnsResolverUtil.java
delete mode 100644
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnectionPool.java
