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 0e0ef10ba9642..da31234095446 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 @@ -105,7 +105,7 @@ public CompletableFuture deleteTopicPoliciesAsync(TopicName topicName) { public CompletableFuture updateTopicPoliciesAsync(TopicName topicName, TopicPolicies policies) { if (NamespaceService.isHeartbeatNamespace(topicName.getNamespaceObject())) { return CompletableFuture.failedFuture(new BrokerServiceException.NotAllowedException( - "Not allowed to send update event to health check topic")); + "Not allowed to update topic policy for the heartbeat topic")); } return sendTopicPolicyEvent(topicName, ActionType.UPDATE, policies); }