This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from a88e96ec9c4 [Branch-2.10][Cherry-pick] tidy update subscriptions
dispatcher rate-limiter (#16778)
new 882d56b466e [fix][flaky-test]
BrokerInterceptorTest.testProducerCreation (#16742)
new 3c7c528b656 Fix Flaky-test:
ManagedLedgerBkTest.asyncMarkDeleteAndClose. (#16730)
new 38be99ce7ee [fix][authorization] Fix multiple roles authorization
(#16645)
new 3a1fc5c1e70 add artifactSet to pom.xml for
pulsar-functions-local-runner (#16565)
new 3e83a5c464f [fix][flaky-test] Fix
BacklogQuotaManagerTest.testConsumerBacklogEvictionTimeQuotaWithEmptyLedger
(#16735)
new ccaebe2447d [fix][flaky-test] Fix PulsarFunctionTlsTest.tearDown
(#16765)
new 1147676c605 fix lafla source config when consumerConfigProperties=''
(#16731)
new c025ce41ad3 [fix][test]Fix
ManagedLedgerTest#avoidUseSameOpAddEntryBetweenDifferentLedger (#16720)
new 53821edfe5f [fix][broker] Fix stats-internal with option -m cause
active ledger recover then close (#16662)
new 73cfe5e81e0 [fix][client]Fix auto cluster failover can't resolve host
bug (#16152)
new 09098edf90d [fix][flaky-test] Fix
PersistentTopicStreamingDispatcherTest (#16801)
new 5d4334165a0 [fix][client] Fix ReconsumeLater will hang up if
retryLetterProducer exception (#16655)
new 2787d1ff3b5 Fix Flaky-test:
PartitionedProducerConsumerTest.testPartitionedTopicInterceptor. (#16809)
new 41d7cf1dab2 [fix][flaky-test] Fix ClassCastException: BrokerService
cannot be cast to class PulsarResources (#16821)
new 39e85f8e2c5 [fix][broker] Avoid IllegalStateException while
client_version is not set (#16788)
new 72af22c58b7 Forget to update memory usage when invalid message (#16835)
new 86ceb3f692f [fix][broker] ManagedCursor: mark delete no callback when
create meta-ledger fail (#16841)
new 1569b177116 [fix][client] Fix load trust certificate (#16789)
new 46293c130e5 [fix][proxy] Fix client service url (#16834)
new 9cb41fd42e5 Fix rack awareness cache expiration race condition (#16825)
new 6e821e89984 fix PatternTopicsChangedListener blocked when topic
removed (#16842)
new c2bb5530b48 [Java Client] Send CloseConsumer on timeout (#16616)
new 7c73269cda7 [fix][client]Fix client memory limit currentUsage leak and
semaphore release duplicated in ProducerImpl (#16837)
new 62ccfaab8fc [fix][broker] Upgrade log4j2 version to 2.18.0 (#16884)
new 2d76839dc28 fix Flaky-test:
PulsarFunctionLocalRunTest.testE2EPulsarFunctionLocalRunMultipleInstance
(#16872)
new 70f1a03925a [fix][client]Fix MaxQueueSize semaphore release leak in
createOpSendMsg (#16915)
new 796dd629e3c [fix][broker] PulsarLedgerManager to pass correct error
code to BK client (#16857)
new 5e4090c96d9 [fix][function] Fix python instance not process zip file
correctly (#16697)
new aaedacfecd1 [improve][authentication] Improve get the basic
authentication config (#16526)
new 0a4add693b5 [improve][authentication] Adapt basic authentication
configuration with prefix (#16935)
new d529ee82fee [improve][test] Verify the authentication data in the
authorization provider (#16900)
new 674f1df3661 [fix][client] Remove redundant check for chunked message
TotalChunkMsgSize in ConsumerImpl (#16797)
new 7b1a81dae0f Fix cherry-pick conflict
The 33 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:
buildtools/pom.xml | 2 +-
conf/broker.conf | 7 +
conf/proxy.conf | 7 +
conf/standalone.conf | 6 +
distribution/server/src/assemble/LICENSE.bin.txt | 8 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 4 +-
.../mledger/impl/ManagedLedgerFactoryImpl.java | 29 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 17 +-
.../mledger/impl/ManagedLedgerBkTest.java | 4 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 26 +-
pom.xml | 10 +-
.../rackawareness/BookieRackAffinityMapping.java | 64 ++---
.../AuthenticationProviderBasic.java | 44 +++-
.../MultiRolesTokenAuthorizationProvider.java | 80 +++++-
.../authorization/PulsarAuthorizationProvider.java | 3 +-
.../BookieRackAffinityMappingTest.java | 12 +-
.../AuthenticationProviderBasicTest.java | 104 ++++++++
.../test/resources/authentication/basic/.htpasswd | 0
.../apache/pulsar/broker/service/ServerCnx.java | 4 +-
.../pulsar/broker/PulsarServiceMockSupport.java | 75 ++++++
.../broker/auth/AuthorizationWithAuthDataTest.java | 292 +++++++++++++++++++++
.../broker/intercept/CounterBrokerInterceptor.java | 66 +++--
.../broker/service/BacklogQuotaManagerTest.java | 35 ++-
.../broker/service/BrokerBkEnsemblesTests.java | 151 ++++++++++-
.../broker/service/MessageCumulativeAckTest.java | 9 +-
.../PersistentDispatcherFailoverConsumerTest.java | 29 +-
.../pulsar/broker/service/PersistentTopicTest.java | 31 ++-
.../broker/service/ServerCnxAuthorizationTest.java | 16 +-
.../pulsar/broker/service/ServerCnxTest.java | 23 ++
.../PersistentTopicStreamingDispatcherTest.java | 2 +-
.../client/api/ClientAuthenticationTlsTest.java | 183 +++++++++++++
.../apache/pulsar/client/api/ClientErrorsTest.java | 47 +++-
.../MultiRolesTokenAuthorizationProviderTest.java | 231 ++++++++++++++++
.../api/PartitionedProducerConsumerTest.java | 2 +
.../apache/pulsar/client/api/RetryTopicTest.java | 61 ++++-
.../client/impl/ProducerMemoryLimitTest.java | 56 ++++
.../pulsar/client/impl/ProducerSemaphoreTest.java | 71 +++++
.../worker/PulsarFunctionLocalRunTest.java | 3 +-
.../functions/worker/PulsarFunctionTlsTest.java | 2 +-
.../pulsar/client/impl/AutoClusterFailover.java | 4 +-
.../client/impl/BatchMessageContainerImpl.java | 3 +
.../apache/pulsar/client/impl/ConsumerImpl.java | 26 +-
.../client/impl/MultiTopicsConsumerImpl.java | 8 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 5 +-
.../client/impl/AutoClusterFailoverTest.java | 2 +
.../apache/pulsar/common/util/SecurityUtility.java | 7 +-
.../src/main/python/python_instance_main.py | 10 +-
pulsar-functions/localrun-shaded/pom.xml | 66 ++++-
.../EnvironmentBasedSecretsProviderTest.java | 25 +-
.../flume/node/TestEnvVarResolverProperties.java | 68 ++---
.../apache/pulsar/io/kafka/KafkaSourceConfig.java | 2 +
.../io/kafka/source/KafkaAbstractSourceTest.java | 19 ++
.../metadata/bookkeeper/PulsarLedgerManager.java | 65 ++++-
.../metadata/impl/AbstractMetadataStore.java | 3 +-
.../pulsar/proxy/server/ProxyConnection.java | 4 +-
.../pulsar/proxy/server/ProxyConnectionTest.java | 24 ++
site2/docs/developing-binary-protocol.md | 9 +
57 files changed, 1893 insertions(+), 273 deletions(-)
create mode 100644
pulsar-broker-common/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasicTest.java
copy {pulsar-broker =>
pulsar-broker-common}/src/test/resources/authentication/basic/.htpasswd (100%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/PulsarServiceMockSupport.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/AuthorizationWithAuthDataTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/ClientAuthenticationTlsTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/MultiRolesTokenAuthorizationProviderTest.java
