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 9799bb0 Use `scheduleWithFixedDelay` instead of `scheduleAtFixedRate`
for java producer batch timer (#14125)
new 68165c8 [Proxy] Remove unnecessary Pulsar Client usage from Pulsar
Proxy (#13836)
new b4733d1 Allow config of IO and acceptor threads in proxy (#14054)
new be806ea [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 | 67 +++----
.../pulsar/common/protocol/PulsarHandler.java | 2 +-
pulsar-proxy/pom.xml | 17 +-
.../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 +
40 files changed, 697 insertions(+), 209 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%)
