diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index acc8c2c2d0c287..854a447723f478 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -554,7 +554,7 @@ private CompletableFuture<Void> removeOrphanReplicationCursors() {
             if (cursor.getName().startsWith(replicatorPrefix)) {
                 String remoteCluster = PersistentReplicator.getRemoteCluster(cursor.getName());
                 if (!replicationClusters.contains(remoteCluster)) {
-                    log.warn("Remove the replicator because the cluster '{}' does not exist", remoteCluster);
+                    log.warn("Remove the orphan replicator because the cluster '{}' does not exist", remoteCluster);
                     futures.add(removeReplicator(remoteCluster));
                 }
             }