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 48ea06c Allow to grant permissions when the authorization is disabled
(#7074)
add 9cdf3fc [PIP-39] Introduce system topic and topic policies service
(#4955)
No new revisions were added by this update.
Summary of changes:
conf/broker.conf | 7 +
conf/standalone.conf | 7 +
.../apache/pulsar/broker/ServiceConfiguration.java | 11 +
.../org/apache/pulsar/broker/PulsarService.java | 14 +
.../pulsar/broker/admin/impl/NamespacesBase.java | 35 ++-
.../pulsar/broker/namespace/NamespaceService.java | 2 +-
.../pulsar/broker/service/BrokerService.java | 39 +--
.../broker/service/BrokerServiceException.java | 6 +
.../SystemTopicBasedTopicPoliciesService.java | 333 +++++++++++++++++++++
.../org/apache/pulsar/broker/service/Topic.java | 4 +
.../broker/service/TopicPoliciesService.java | 110 +++++++
.../broker/service/persistent/PersistentTopic.java | 36 ++-
.../broker/service/persistent/SystemTopic.java | 38 +--
.../NamespaceEventsSystemTopicFactory.java | 58 ++++
.../pulsar/broker/systopic/SystemTopicClient.java | 175 +++++++++++
.../broker/systopic/SystemTopicClientBase.java | 117 ++++++++
.../systopic/TopicPoliciesSystemTopicClient.java | 166 ++++++++++
.../apache/pulsar/broker/admin/AdminApiTest.java | 10 +-
.../apache/pulsar/broker/admin/NamespacesTest.java | 2 +-
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 12 +-
.../broker/auth/MockedPulsarServiceBaseTest.java | 6 +-
.../AntiAffinityNamespaceGroupTest.java | 2 +-
.../namespace/NamespaceOwnershipListenerTests.java | 2 +-
.../pulsar/broker/service/BrokerServiceTest.java | 4 +-
.../broker/service/PersistentTopicE2ETest.java | 2 +-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 188 ++++++++++++
.../TopicPoliciesServiceDisableTest.java} | 37 +--
.../pulsar/broker/stats/PrometheusMetricsTest.java | 2 +-
.../NamespaceEventsSystemTopicServiceTest.java | 118 ++++++++
.../websocket/proxy/ProxyPublishConsumeTest.java | 2 +-
.../apache/pulsar/common/events/ActionType.java | 11 +-
.../EventType.java} | 10 +-
.../pulsar/common/events/EventsTopicNames.java | 14 +-
.../PulsarEvent.java} | 13 +-
.../TopicPoliciesEvent.java} | 16 +-
.../apache/pulsar/common/events}/package-info.java | 2 +-
.../pulsar/common/policies/data/Policies.java | 6 +-
.../pulsar/common/policies/data/TopicPolicies.java | 80 +++++
38 files changed, 1564 insertions(+), 133 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicPoliciesService.java
copy
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/EventImpl.java
=>
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SystemTopic.java
(52%)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicFactory.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClient.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/SystemTopicClientBase.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TopicPoliciesSystemTopicClient.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesServiceTest.java
copy
pulsar-broker/src/test/java/org/apache/pulsar/broker/{namespace/NamespaceCreateBundlesTest.java
=> service/TopicPoliciesServiceDisableTest.java} (55%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicServiceTest.java
copy
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Sink.java =>
pulsar-common/src/main/java/org/apache/pulsar/common/events/ActionType.java
(85%)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/{policies/data/PersistentTopicStats.java
=> events/EventType.java} (84%)
copy
pulsar-io/core/src/main/java/org/apache/pulsar/io/core/annotations/IOType.java
=>
pulsar-common/src/main/java/org/apache/pulsar/common/events/EventsTopicNames.java
(77%)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/{protocol/schema/LongSchemaVersionResponse.java
=> events/PulsarEvent.java} (82%)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/{protocol/schema/IsCompatibilityResponse.java
=> events/TopicPoliciesEvent.java} (76%)
copy {pulsar-io/file/src/main/java/org/apache/pulsar/io/file =>
pulsar-common/src/main/java/org/apache/pulsar/common/events}/package-info.java
(95%)
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java
