From 52133927f32616dc59536a69c300f26ac0a0696e Mon Sep 17 00:00:00 2001 From: Qiang Zhao Date: Fri, 6 Oct 2023 15:04:56 +0800 Subject: [PATCH] Fix checkstyle --- .../service/SystemTopicBasedTopicPoliciesService.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java index bb7d041325d28e..daa2b249a9ca69 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java @@ -56,7 +56,6 @@ import org.apache.pulsar.common.naming.TopicName; import org.apache.pulsar.common.policies.data.TopicPolicies; import org.apache.pulsar.common.util.FutureUtil; -import org.jetbrains.annotations.NotNull; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -245,9 +244,9 @@ public TopicPolicies getTopicPolicies(TopicName topicName, } } - @NotNull + @Nonnull @Override - public CompletableFuture> getTopicPoliciesAsync(@NotNull TopicName topicName, + public CompletableFuture> getTopicPoliciesAsync(@Nonnull TopicName topicName, boolean isGlobal) { requireNonNull(topicName); final CompletableFuture preparedFuture = prepareInitPoliciesCacheAsync(topicName.getNamespaceObject()); @@ -259,9 +258,9 @@ public CompletableFuture> getTopicPoliciesAsync(@NotNull }); } - @NotNull + @Nonnull @Override - public CompletableFuture> getTopicPoliciesAsync(@NotNull TopicName topicName) { + public CompletableFuture> getTopicPoliciesAsync(@Nonnull TopicName topicName) { requireNonNull(topicName); final CompletableFuture preparedFuture = prepareInitPoliciesCacheAsync(topicName.getNamespaceObject()); return preparedFuture.thenApply(__ -> {