Skip to content

Commit d3ca28b

Browse files
committed
address comment
1 parent 011442c commit d3ca28b

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -527,7 +527,7 @@ private CompletableFuture<Set<String>> getReplicationClusters() {
527527
}
528528

529529
protected void internalCreateMissedPartitions(AsyncResponse asyncResponse) {
530-
pulsar().getBrokerService().isAllowedCurrentClusterAccess(topicName).thenAccept(allowed -> {
530+
pulsar().getBrokerService().isCurrentClusterAllowed(topicName).thenAccept(allowed -> {
531531
if (!allowed) {
532532
resumeAsyncResponseExceptionally(asyncResponse,
533533
new RestException(Status.BAD_REQUEST, String.format("Topic [%s] is not allowed to be loaded"

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4049,7 +4049,7 @@ public boolean isCurrentClusterAllowed(NamespaceName nsName, Policies nsPolicies
40494049
/**
40504050
* @return Triple [namespace policies, global topic policies, topic policies].
40514051
*/
4052-
public CompletableFuture<Boolean> isAllowedCurrentClusterAccess(@NonNull TopicName topicName) {
4052+
public CompletableFuture<Boolean> isCurrentClusterAllowed(@NonNull TopicName topicName) {
40534053
final String cluster = getPulsar().getConfig().getClusterName();
40544054
return getCombinedTopicPolicies(topicName).thenApply(triple -> {
40554055
Optional<TopicPolicies> topicP = triple.getRight();

0 commit comments

Comments
 (0)