This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 4574b55920f [fix][build] Remove invalid profile in settings.xml that
caused gpg signing to fail (#24812)
new bd5135ec329 [fix][client] Add description method to ClientBuilder
(#24728)
new eabfdbd7c9a [improve][client] Allow adding custom description to
User-Agent header (#24729)
new 80e9fef353d [fix][client] Fix PulsarAdmin description check and add
test (#24734)
new 29e2a73bf73 [feat][client] Implement PIP-234 for sharing thread pools
and DNS resolver/cache across multiple Pulsar Client instances (#24790)
The 4 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:
build/run_unit_group.sh | 5 +-
.../org/apache/pulsar/broker/PulsarService.java | 2 +-
.../broker/auth/MockedPulsarServiceBaseTest.java | 15 +-
.../broker/service/ExclusiveProducerTest.java | 2 +
.../broker/service/TopicTerminationTest.java | 2 +
.../pulsar/client/api/ConsumerCleanupTest.java | 2 +
.../pulsar/client/api/ProducerCleanupTest.java | 2 +
...MultiListenersWithInternalListenerNameTest.java | 8 +-
.../client/api/SimpleProducerConsumerTest.java | 61 ++++-
.../pulsar/client/impl/PulsarTestClient.java | 2 +-
.../pulsar/client/impl/TopicDoesNotExistsTest.java | 4 +-
.../pulsar/client/admin/PulsarAdminBuilder.java | 17 ++
.../admin/internal/PulsarAdminBuilderImpl.java | 9 +
.../admin/internal/http/AsyncHttpConnector.java | 5 +-
.../admin/internal/PulsarAdminBuilderImplTest.java | 16 ++
.../apache/pulsar/client/api/ClientBuilder.java | 31 +++
.../pulsar/client/api/DnsResolverConfig.java | 126 +++++++++
.../{Messages.java => EventLoopGroupConfig.java} | 18 +-
.../client/api/PulsarClientSharedResources.java | 127 +++++++++
.../api/PulsarClientSharedResourcesBuilder.java | 122 +++++++++
...oducerAccessMode.java => ThreadPoolConfig.java} | 31 ++-
.../api/{MessagePayload.java => TimerConfig.java} | 25 +-
.../PulsarClientImplementationBinding.java | 3 +
.../pulsar/client/impl/AutoClusterFailover.java | 11 +-
.../pulsar/client/impl/ClientBuilderImpl.java | 36 +--
.../apache/pulsar/client/impl/ConnectionPool.java | 2 +-
.../client/impl/ControlledClusterFailover.java | 26 +-
.../pulsar/client/impl/DnsResolverGroupImpl.java | 54 +++-
.../org/apache/pulsar/client/impl/HttpClient.java | 19 +-
.../pulsar/client/impl/HttpLookupService.java | 14 +-
.../pulsar/client/impl/PulsarClientImpl.java | 67 ++---
.../PulsarClientImplementationBindingImpl.java | 6 +
.../impl/PulsarClientResourcesConfigurer.java | 149 +++++++++++
.../PulsarClientSharedResourcesBuilderImpl.java | 283 +++++++++++++++++++++
.../impl/PulsarClientSharedResourcesImpl.java | 160 ++++++++++++
.../pulsar/client/util/ExecutorProvider.java | 6 +-
.../client/util/ScheduledExecutorProvider.java | 3 +
.../src/main/resources/findbugsExclude.xml | 9 +
.../pulsar/client/impl/ClientBuilderImplTest.java | 17 ++
.../client/impl/ControlledClusterFailoverTest.java | 6 +
...PulsarClientSharedResourcesBuilderImplTest.java | 136 ++++++++++
.../pulsar/common/util/netty/DnsResolverUtil.java | 118 ++++++++-
.../pulsar/common/util/netty/EventLoopUtil.java | 76 +++++-
.../pulsar/common/util/netty/DnsResolverTest.java | 1 +
.../common/util/netty/DnsResolverUtilTest.java | 68 +++++
45 files changed, 1769 insertions(+), 133 deletions(-)
create mode 100644
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/DnsResolverConfig.java
copy
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/{Messages.java =>
EventLoopGroupConfig.java} (68%)
create mode 100644
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientSharedResources.java
create mode 100644
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientSharedResourcesBuilder.java
copy
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/{ProducerAccessMode.java
=> ThreadPoolConfig.java} (54%)
copy
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/{MessagePayload.java
=> TimerConfig.java} (61%)
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientResourcesConfigurer.java
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientSharedResourcesBuilderImpl.java
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientSharedResourcesImpl.java
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/PulsarClientSharedResourcesBuilderImplTest.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/util/netty/DnsResolverUtilTest.java
