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/12/15 08:26:18 UTC
[pulsar] branch master updated (72a5c3c -> c6beb35)
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 72a5c3c [Broker] Support create subscription by specifying the earliest or latest position. (#12872)
add c6beb35 PIP 92: part-2 Topic policy across multiple clusters (#12517)
No new revisions were added by this update.
Summary of changes:
.../apache/pulsar/broker/admin/AdminResource.java | 8 +-
.../broker/admin/impl/PersistentTopicsBase.java | 27 ++---
.../pulsar/broker/admin/v2/PersistentTopics.java | 9 +-
.../SystemTopicBasedTopicPoliciesService.java | 48 +++++++-
.../broker/service/TopicPoliciesService.java | 18 ++-
.../broker/service/persistent/PersistentTopic.java | 13 ++-
.../broker/service/persistent/SystemTopic.java | 5 +
.../systopic/TopicPoliciesSystemTopicClient.java | 25 ++++-
.../pulsar/broker/admin/TopicPoliciesTest.java | 46 ++++++++
.../pulsar/broker/service/PersistentTopicTest.java | 3 +-
.../pulsar/broker/service/ReplicatorTest.java | 54 ++++++---
.../service/ReplicatorTopicPoliciesTest.java | 115 +++++++++++++++++++
.../SystemTopicBasedTopicPoliciesServiceTest.java | 5 +-
.../pulsar/admin/cli/PulsarAdminToolTest.java | 45 ++++++--
.../apache/pulsar/admin/cli/CmdTopicPolicies.java | 125 +++++++++++++++++++++
.../org/apache/pulsar/admin/cli/CmdTopics.java | 4 +
.../apache/pulsar/admin/cli/PulsarAdminTool.java | 1 +
.../org/apache/pulsar/client/impl/MessageImpl.java | 1 -
.../pulsar/client/impl/TopicMessageImpl.java | 1 +
.../pulsar/common/events/EventsTopicNames.java | 7 ++
.../apache/pulsar/common/events/PulsarEvent.java | 5 +
.../pulsar/common/policies/data/TopicPolicies.java | 5 +
22 files changed, 509 insertions(+), 61 deletions(-)
create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorTopicPoliciesTest.java
create mode 100644 pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopicPolicies.java