This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 6a744def026 [fix][python]Fix generated Python protobuf code not
compatible with latest protobuf package (#15846)
new 03fb6edde16 [Proxy] Log warning when opening connection to broker
fails #14710
new 6bafef1beb0 Fail proxy startup if brokerServiceURL is missing scheme
(#14682)
new 58ad46722c2 [refactor][proxy] Refactor Proxy code and fix connection
stalling by switching to auto read mode (#14713)
new 837cfbd9a7b [Proxy & Client] Configure Netty DNS resolver to match JDK
DNS caching setting, share DNS resolver instance in Proxy (#15219)
new 8115076c511 [Proxy] Fix proxy connection leak when inbound connection
closes while connecting is in progress (#15366)
new 7c0eab26a6d [Proxy/Client] Fix DNS server denial-of-service issue when
DNS entry expires (#15403)
new 462d44f906f [Proxy] Remove unnecessary blocking DNS lookup in
LookupProxyHandler (#15415)
new dbe0518554b [Proxy] Prevent leak of unreleased lookupRequestSemaphore
permits (#13812)
new 0348502a206 Switch to rely on Netty for Hostname Verification (#15824)
new e5d035ae413 Configure DLog Bookie, Pulsar, and Admin clients via pass
through config (#15818)
The 10 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:
.../resources/authentication/tls/broker-cert.pem | 74 +++---
.../test/resources/authentication/tls/cacert.pem | 109 ++++----
.../resources/authentication/tls/client-cert.pem | 87 ++++---
build/regenerate_certs_for_tests.sh | 70 +++++
conf/broker.conf | 14 +-
conf/functions_worker.yml | 20 ++
conf/proxy.conf | 7 +-
conf/websocket.conf | 4 +
.../pulsar/broker/BookKeeperClientFactoryImpl.java | 16 +-
.../org/apache/pulsar/broker/PulsarService.java | 32 ++-
.../pulsar/broker/namespace/NamespaceService.java | 10 +-
.../pulsar/broker/service/BrokerService.java | 21 +-
.../apache/pulsar/compaction/CompactorTool.java | 6 +
...kerInternalClientConfigurationOverrideTest.java | 103 ++++++++
.../AuthenticationTlsHostnameVerificationTest.java | 58 ++---
.../pulsar/client/impl/ConnectionPoolTest.java | 38 +--
.../PulsarClientConfigurationOverrideTest.java | 56 ++++
.../websocket/proxy/ProxyConfigurationTest.java | 8 +-
.../pulsar/client/admin/PulsarAdminBuilder.java | 23 ++
.../admin/internal/PulsarAdminBuilderImpl.java | 9 +-
.../admin/internal/http/AsyncHttpConnector.java | 9 +-
.../pulsar/client/internal/PropertiesUtils.java | 64 +++++
.../org/apache/pulsar/client/impl/ClientCnx.java | 48 ----
.../apache/pulsar/client/impl/ConnectionPool.java | 66 +++--
.../org/apache/pulsar/client/impl/HttpClient.java | 1 +
.../client/impl/PulsarChannelInitializer.java | 7 +
pulsar-common/pom.xml | 5 +
.../util/NettyClientSslContextRefresher.java | 3 +-
.../apache/pulsar/common/util/SecurityUtility.java | 10 +
.../pulsar/common/util/netty/DnsResolverUtil.java | 75 ++++++
.../src/test/resources/test_worker_config.yml | 3 +
.../pulsar/functions/worker/WorkerService.java | 7 +-
.../pulsar/functions/worker/WorkerUtils.java | 45 +++-
.../pulsar/functions/worker/WorkerUtilsTest.java | 27 +-
.../pulsar/proxy/server/AdminProxyHandler.java | 7 +-
.../pulsar/proxy/server/BrokerProxyValidator.java | 2 +-
.../pulsar/proxy/server/DirectProxyHandler.java | 284 +++++++++++----------
.../pulsar/proxy/server/LookupProxyHandler.java | 123 +++++----
.../pulsar/proxy/server/ParserProxyHandler.java | 114 +++++----
.../pulsar/proxy/server/ProxyConfiguration.java | 4 +-
.../pulsar/proxy/server/ProxyConnection.java | 219 ++++++++++------
.../pulsar/proxy/server/ProxyConnectionPool.java | 60 -----
.../apache/pulsar/proxy/server/ProxyService.java | 15 +-
.../pulsar/proxy/server/ProxyServiceStarter.java | 10 +
.../proxy/server/ServiceChannelInitializer.java | 58 +----
.../proxy/server/BrokerProxyValidatorTest.java | 20 ++
.../proxy/server/ProxyWithAuthorizationTest.java | 70 ++---
.../ProxyWithAuthorizationTest/broker-cacert.pem | 109 ++++----
.../tls/ProxyWithAuthorizationTest/broker-cert.pem | 86 +++----
.../ProxyWithAuthorizationTest/client-cacert.pem | 109 ++++----
.../tls/ProxyWithAuthorizationTest/client-cert.pem | 86 +++----
.../ProxyWithAuthorizationTest/proxy-cacert.pem | 109 ++++----
.../tls/ProxyWithAuthorizationTest/proxy-cert.pem | 86 +++----
.../test/resources/authentication/tls/cacert.pem | 109 ++++----
.../resources/authentication/tls/client-cert.pem | 87 ++++---
.../resources/authentication/tls/server-cert.pem | 87 ++++---
.../apache/pulsar/websocket/WebSocketService.java | 7 +-
site2/docs/reference-configuration.md | 26 +-
58 files changed, 1820 insertions(+), 1202 deletions(-)
create mode 100755 build/regenerate_certs_for_tests.sh
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerInternalClientConfigurationOverrideTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PulsarClientConfigurationOverrideTest.java
create mode 100644
pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/PropertiesUtils.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/netty/DnsResolverUtil.java
copy
pulsar-common/src/test/java/org/apache/pulsar/common/policies/data/PersistencePoliciesTest.java
=>
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/WorkerUtilsTest.java
(53%)
delete mode 100644
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnectionPool.java
