This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 91dfa1a Introduce maxMessagePublishBufferSizeInMB configuration to
avoid broker OOM (#6178)
add df15210 Enable get precise backlog and backlog without delayed
messages. (#6310)
No new revisions were added by this update.
Summary of changes:
conf/broker.conf | 5 +
conf/standalone.conf | 5 +
.../apache/bookkeeper/mledger/ManagedCursor.java | 3 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 6 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 7 +
.../mledger/impl/ManagedLedgerMBeanImpl.java | 2 +-
.../mledger/impl/ManagedCursorContainerTest.java | 2 +-
.../mledger/impl/ManagedCursorListAckTest.java | 8 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 132 +++++++--------
.../mledger/impl/ManagedLedgerBkTest.java | 14 +-
.../mledger/impl/ManagedLedgerErrorsTest.java | 8 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 12 +-
.../mledger/impl/NonDurableCursorTest.java | 36 ++--
.../apache/pulsar/broker/ServiceConfiguration.java | 8 +
.../broker/admin/impl/PersistentTopicsBase.java | 8 +-
.../broker/admin/v1/NonPersistentTopics.java | 2 +-
.../pulsar/broker/admin/v1/PersistentTopics.java | 4 +-
.../broker/admin/v2/NonPersistentTopics.java | 6 +-
.../pulsar/broker/admin/v2/PersistentTopics.java | 14 +-
.../pulsar/broker/service/BacklogQuotaManager.java | 2 +-
.../pulsar/broker/service/BrokerService.java | 2 +-
.../apache/pulsar/broker/service/ServerCnx.java | 2 +-
.../apache/pulsar/broker/service/Subscription.java | 2 +-
.../org/apache/pulsar/broker/service/Topic.java | 2 +-
.../nonpersistent/NonPersistentSubscription.java | 2 +-
.../service/nonpersistent/NonPersistentTopic.java | 6 +-
.../service/persistent/CompactorSubscription.java | 2 +-
.../PersistentDispatcherMultipleConsumers.java | 2 +-
.../PersistentDispatcherSingleActiveConsumer.java | 2 +-
.../persistent/PersistentMessageExpiryMonitor.java | 4 +-
.../service/persistent/PersistentReplicator.java | 16 +-
.../service/persistent/PersistentSubscription.java | 31 ++--
.../broker/service/persistent/PersistentTopic.java | 10 +-
.../stats/prometheus/AggregatedNamespaceStats.java | 1 +
.../prometheus/AggregatedSubscriptionStats.java | 2 +
.../stats/prometheus/NamespaceStatsAggregator.java | 13 +-
.../pulsar/broker/stats/prometheus/TopicStats.java | 1 +
.../apache/pulsar/broker/admin/AdminApiTest2.java | 183 +++++++++++++++++++++
.../pulsar/broker/service/BatchMessageTest.java | 42 ++---
.../pulsar/broker/service/BrokerServiceTest.java | 18 +-
.../broker/service/PersistentFailoverE2ETest.java | 10 +-
.../broker/service/PersistentQueueE2ETest.java | 4 +-
.../broker/service/PersistentTopicE2ETest.java | 18 +-
.../broker/service/SubscriptionSeekTest.java | 20 +--
.../prometheus/AggregatedNamespaceStatsTest.java | 3 +
.../client/api/DispatcherBlockConsumerTest.java | 4 +-
.../pulsar/client/api/NonPersistentTopicTest.java | 10 +-
.../pulsar/client/impl/MessageParserTest.java | 2 +-
.../pulsar/client/impl/TopicsConsumerImplTest.java | 4 +-
.../org/apache/pulsar/client/admin/Topics.java | 28 +++-
.../pulsar/client/admin/internal/TopicsImpl.java | 16 +-
.../pulsar/admin/cli/PulsarAdminToolTest.java | 4 +-
.../org/apache/pulsar/admin/cli/CmdTopics.java | 12 +-
.../common/policies/data/SubscriptionStats.java | 5 +
site2/docs/admin-api-non-partitioned-topics.md | 56 +++++++
site2/docs/admin-api-partitioned-topics.md | 5 +-
site2/docs/reference-configuration.md | 2 +
57 files changed, 577 insertions(+), 253 deletions(-)
