[fix][broker]correct the 'ReplicatorStatsImpl.connected' default value

apache · Oct 28, 2024 · 83a3375 · 83a3375
1 parent cfa9117
commit 83a3375
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ommon/src/main/java/org/apache/pulsar/common/policies/data/stats/ReplicatorStatsImpl.java b/...ommon/src/main/java/org/apache/pulsar/common/policies/data/stats/ReplicatorStatsImpl.java
@@ -62,7 +62,7 @@ public class ReplicatorStatsImpl implements ReplicatorStats {
     public long replicationBacklog;
 
     /** is the replication-subscriber up and running to replicate to remote cluster. */
-    public boolean connected;
+    public boolean connected = true;
 
     /** Time in seconds from the time a message was produced to the time when it is about to be replicated. */
     public long replicationDelayInSeconds;