This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from edace66 [docs] Update Websocket content (#8762) (#8777)
new 508dfb3 Clear delayed messages when clear backlog. (#8691)
new 4b59b38 [Transaction] Fix transaction log replay not handle right.
(#8723)
new 11a96e8 [C++] Fixed flaky test:
AuthPluginTest.testTlsDetectHttpsWithHostNameValidation (#8771)
new c7efdcc [C++] Implement batch aware producer router (#8395)
new b27902a Fix the problem that batchMessageId is converted to
messageIdImpl (#8779)
new 7150504 Issue 8704: improve env config handling (#8709)
new c00aac7 [Doc]--Update doc for multiple advertised listeners (#8789)
The 7 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:
conf/broker.conf | 2 +-
docker/pulsar/scripts/apply-config-from-env.py | 39 ++++-
.../apache/pulsar/broker/ServiceConfiguration.java | 2 +-
.../broker/TransactionMetadataStoreService.java | 27 ++--
.../broker/delayed/DelayedDeliveryTracker.java | 5 +
.../delayed/InMemoryDelayedDeliveryTracker.java | 5 +
.../broker/service/BrokerServiceException.java | 2 +
.../apache/pulsar/broker/service/Dispatcher.java | 4 +
.../apache/pulsar/broker/service/ServerCnx.java | 77 +++++-----
.../PersistentDispatcherMultipleConsumers.java | 5 +
.../service/persistent/PersistentSubscription.java | 1 +
.../TransactionMetadataStoreServiceTest.java | 17 ++-
.../service/persistent/DelayedDeliveryTest.java | 31 ++++
.../TransactionCoordinatorClientTest.java | 2 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 72 ++++++++-
.../client/impl/TransactionEndToEndTest.java | 8 +-
.../TransactionCoordinatorClientException.java | 9 ++
pulsar-client-cpp/include/pulsar/Result.h | 1 +
pulsar-client-cpp/lib/ClientConnection.cc | 3 +
pulsar-client-cpp/lib/PartitionedProducerImpl.cc | 5 +-
pulsar-client-cpp/lib/Result.cc | 3 +
pulsar-client-cpp/lib/RoundRobinMessageRouter.cc | 63 +++++++-
pulsar-client-cpp/lib/RoundRobinMessageRouter.h | 26 +++-
pulsar-client-cpp/tests/AuthPluginTest.cc | 34 ++---
pulsar-client-cpp/tests/BasicEndToEndTest.cc | 4 +-
pulsar-client-cpp/tests/CustomRoutingPolicy.h | 13 ++
pulsar-client-cpp/tests/PartitionsUpdateTest.cc | 3 +-
.../tests/RoundRobinMessageRouterTest.cc | 164 ++++++++++++++++-----
.../client/impl/TransactionMetaStoreHandler.java | 2 +
.../apache/pulsar/common/api/proto/PulsarApi.java | 3 +
.../util/collections/TripleLongPriorityQueue.java | 8 +
pulsar-common/src/main/proto/PulsarApi.proto | 1 +
.../TransactionMetadataStoreProvider.java | 9 +-
.../InMemTransactionMetadataStoreProvider.java | 5 +-
.../coordinator/impl/MLTransactionLogImpl.java | 27 ++--
.../impl/MLTransactionMetadataStoreProvider.java | 10 +-
.../MLTransactionMetadataStoreTest.java | 14 +-
.../TransactionMetadataStoreProviderTest.java | 2 +-
.../docs/concepts-multiple-advertised-listeners.md | 38 +++++
site2/website/sidebars.json | 3 +-
.../version-2.6.1/reference-configuration.md | 2 +
.../version-2.6.2/reference-configuration.md | 2 +
42 files changed, 587 insertions(+), 166 deletions(-)
create mode 100644 site2/docs/concepts-multiple-advertised-listeners.md
