From 69d2abd50fc6e9ca8b6f514614b930843f0c6855 Mon Sep 17 00:00:00 2001
From: fengyubiao <yubiao.feng@streamnative.io>
Date: Fri, 14 Jun 2024 18:34:50 +0800
Subject: [PATCH] change the log

---
 .../pulsar/broker/service/persistent/PersistentTopic.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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));
                 }
             }