You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/04/21 14:42:49 UTC

[pulsar] branch master updated (e542c14 -> d1a439b)

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from e542c14  Release procedure: fix paths for docker-build-deb.sh and docker-build-rpm.sh (#10302)
     add d1a439b  [Broker] Add time based backlog quota (#10093)

No new revisions were added by this update.

Summary of changes:
 .../bookkeeper/mledger/impl/ManagedLedgerImpl.java |   4 +
 .../apache/pulsar/broker/ServiceConfiguration.java |  24 +-
 .../apache/pulsar/broker/admin/AdminResource.java  |   2 +-
 .../pulsar/broker/service/BacklogQuotaManager.java |  80 ++++-
 .../pulsar/broker/service/BrokerService.java       |  10 +-
 .../service/persistent/PersistentSubscription.java |   4 +
 .../broker/service/persistent/PersistentTopic.java |  91 ++++-
 .../broker/service/persistent/SystemTopic.java     |   7 +-
 .../stats/prometheus/AggregatedNamespaceStats.java |   3 +
 .../stats/prometheus/NamespaceStatsAggregator.java |   3 +-
 .../pulsar/broker/stats/prometheus/TopicStats.java |   4 +
 .../broker/service/BacklogQuotaManagerTest.java    | 391 ++++++++++++++++++++-
 .../org/apache/pulsar/client/api/Consumer.java     |   4 +-
 .../pulsar/common/policies/data/BacklogQuota.java  |  47 ++-
 .../metadata/BacklogQuotaCompatibilityTest.java    |  54 +++
 15 files changed, 684 insertions(+), 44 deletions(-)
 create mode 100644 pulsar-metadata/src/test/java/org/apache/pulsar/metadata/BacklogQuotaCompatibilityTest.java