From 83a3375c6ff7ed29cd24c85763e2da48d10d5b73 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9E=97=E5=AE=87=E5=BC=BA?= <lylelin@tencent.com>
Date: Mon, 28 Oct 2024 17:46:21 +0800
Subject: [PATCH] [fix][broker]correct the 'ReplicatorStatsImpl.connected'
 default value

---
 .../pulsar/common/policies/data/stats/ReplicatorStatsImpl.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/ReplicatorStatsImpl.java b/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/ReplicatorStatsImpl.java
index c19169cbee57f..21f64372bd97e 100644
--- a/pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/ReplicatorStatsImpl.java
+++ b/pulsar-common/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;