You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rd...@apache.org on 2019/10/25 07:06:33 UTC
[pulsar] branch master updated (13e35f7 -> 7686542)

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

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


    from 13e35f7  [PIP-43] Support producer to send msg with different schema (#5165)
     add 7686542  [pulsar-broker] Introduce publish rate-limiting on topic (#3986)

No new revisions were added by this update.

Summary of changes:
 conf/broker.conf                                   |   4 +
 conf/standalone.conf                               |   5 +
 .../apache/pulsar/broker/ServiceConfiguration.java |   8 +
 .../pulsar/broker/admin/impl/NamespacesBase.java   |  51 ++++++
 .../apache/pulsar/broker/admin/v1/Namespaces.java  |  22 +++
 .../apache/pulsar/broker/admin/v2/Namespaces.java  |  21 +++
 .../pulsar/broker/service/AbstractTopic.java       |  98 ++++++++++-
 .../pulsar/broker/service/BrokerService.java       |  49 ++++++
 .../org/apache/pulsar/broker/service/Producer.java |  11 +-
 .../pulsar/broker/service/PublishRateLimiter.java  | 163 ++++++++++++++++++
 .../broker/service/PulsarChannelInitializer.java   |   7 +
 .../apache/pulsar/broker/service/ServerCnx.java    |  31 +++-
 .../org/apache/pulsar/broker/service/Topic.java    |   8 +
 .../service/nonpersistent/NonPersistentTopic.java  |  16 +-
 .../broker/service/persistent/PersistentTopic.java |  48 +++---
 .../client/impl/MessagePublishThrottlingTest.java  | 186 +++++++++++++++++++++
 .../org/apache/pulsar/client/admin/Namespaces.java |  22 +++
 .../client/admin/internal/NamespacesImpl.java      |  25 +++
 .../pulsar/admin/cli/PulsarAdminToolTest.java      |   7 +
 .../org/apache/pulsar/admin/cli/CmdNamespaces.java |  37 ++++
 .../pulsar/common/policies/data/Policies.java      |   5 +-
 .../data/{SubscribeRate.java => PublishRate.java}  |  37 ++--
 22 files changed, 799 insertions(+), 62 deletions(-)
 create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java
 create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessagePublishThrottlingTest.java
 copy pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/{SubscribeRate.java => PublishRate.java} (50%)