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 53bc099dc5fd5..315de982df89d 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 @@ -175,8 +175,7 @@ public CompletableFuture getTopicPoliciesBypassCacheAsync(TopicNa public CompletableFuture addOwnedNamespaceBundleAsync(NamespaceBundle namespaceBundle) { CompletableFuture result = new CompletableFuture<>(); NamespaceName namespace = namespaceBundle.getNamespaceObject(); - if (NamespaceService.checkHeartbeatNamespace(namespace) != null - || NamespaceService.checkHeartbeatNamespaceV2(namespace) != null) { + if (NamespaceService.checkHeartbeatNamespace(namespace) != null) { result.complete(null); return result; } @@ -210,8 +209,7 @@ public CompletableFuture addOwnedNamespaceBundleAsync(NamespaceBundle name @Override public CompletableFuture removeOwnedNamespaceBundleAsync(NamespaceBundle namespaceBundle) { NamespaceName namespace = namespaceBundle.getNamespaceObject(); - if (NamespaceService.checkHeartbeatNamespace(namespace) != null - || NamespaceService.checkHeartbeatNamespaceV2(namespace) != null) { + if (NamespaceService.checkHeartbeatNamespace(namespace) != null) { return CompletableFuture.completedFuture(null); } AtomicInteger bundlesCount = ownedBundlesCountPerNamespace.get(namespace); diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java index 035950e7c493e..bfb77159dbb63 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java @@ -2300,7 +2300,6 @@ public void testDoNotCreateSystemTopicForHeartbeatNamespace() { pulsar.getBrokerService().getTopics().forEach((k, v) -> { TopicName topicName = TopicName.get(k); assertNull(NamespaceService.checkHeartbeatNamespace(topicName.getNamespaceObject())); - assertNull(NamespaceService.checkHeartbeatNamespaceV2(topicName.getNamespaceObject())); }); }