This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 7716894 AbstractMetadataStore: invalidate childrenCache correctly
when node created (#14177)
new 25e6b65 [Proxy] Remove unnecessary Pulsar Client usage from Pulsar
Proxy (#13836)
new 1742df8 Allow config of IO and acceptor threads in proxy (#14054)
new 3d2e6ce [Proxy] Fix port exhaustion and connection issues in Pulsar
Proxy (#14078)
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:
distribution/server/src/assemble/LICENSE.bin.txt | 2 +
pom.xml | 1 +
.../ProxySaslAuthenticationTest.java | 1 +
.../apache/pulsar/client/impl/ConnectionPool.java | 62 +++----
.../pulsar/common/protocol/PulsarHandler.java | 2 +-
pulsar-proxy/pom.xml | 13 +-
.../proxy/server/BrokerDiscoveryProvider.java | 10 +
.../pulsar/proxy/server/BrokerProxyValidator.java | 181 ++++++++++++++++++
.../pulsar/proxy/server/DirectProxyHandler.java | 154 ++++++++-------
.../pulsar/proxy/server/ProxyConfiguration.java | 53 ++++++
.../pulsar/proxy/server/ProxyConnection.java | 206 ++++++++++++++-------
.../apache/pulsar/proxy/server/ProxyService.java | 36 ++--
.../pulsar/proxy/server/ProxyServiceStarter.java | 2 +
.../proxy/server/ServiceChannelInitializer.java | 8 +
.../proxy/server/TargetAddressDeniedException.java | 10 +-
.../proxy/server/AuthedAdminProxyHandlerTest.java | 1 +
.../proxy/server/BrokerProxyValidatorTest.java | 102 ++++++++++
.../proxy/server/ProxyAdditionalServletTest.java | 1 +
.../ProxyAuthenticatedProducerConsumerTest.java | 1 +
.../proxy/server/ProxyAuthenticationTest.java | 1 +
.../pulsar/proxy/server/ProxyConnectionTest.java | 21 ++-
.../server/ProxyConnectionThrottlingTest.java | 1 +
.../server/ProxyEnableHAProxyProtocolTest.java | 1 +
.../proxy/server/ProxyForwardAuthDataTest.java | 1 +
.../proxy/server/ProxyKeyStoreTlsTestWithAuth.java | 1 +
.../server/ProxyKeyStoreTlsTestWithoutAuth.java | 1 +
.../proxy/server/ProxyLookupThrottlingTest.java | 1 +
.../pulsar/proxy/server/ProxyParserTest.java | 1 +
.../proxy/server/ProxyRolesEnforcementTest.java | 1 +
.../proxy/server/ProxyServiceStarterTest.java | 5 +-
.../proxy/server/ProxyServiceTlsStarterTest.java | 15 +-
.../apache/pulsar/proxy/server/ProxyStatsTest.java | 1 +
.../org/apache/pulsar/proxy/server/ProxyTest.java | 1 +
.../apache/pulsar/proxy/server/ProxyTlsTest.java | 1 +
.../pulsar/proxy/server/ProxyTlsTestWithAuth.java | 1 +
.../server/ProxyWithAuthorizationNegTest.java | 1 +
.../proxy/server/ProxyWithAuthorizationTest.java | 2 +
.../server/ProxyWithJwtAuthorizationTest.java | 1 +
.../server/ProxyWithoutServiceDiscoveryTest.java | 1 +
.../SuperUserAuthedAdminProxyHandlerTest.java | 1 +
.../server/UnauthedAdminProxyHandlerTest.java | 1 +
41 files changed, 705 insertions(+), 202 deletions(-)
create mode 100644
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/BrokerProxyValidator.java
copy
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/StringSource.java
=>
pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/TargetAddressDeniedException.java
(81%)
create mode 100644
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/BrokerProxyValidatorTest.java
copy
pulsar-common/src/test/java/org/apache/pulsar/common/policies/impl/MinAvailablePolicyTest.java
=>
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyConnectionTest.java
(59%)
