Fix: handle failure of topic stat update
@@ -1127,7 +1127,12 @@ public class PersistentTopic implements Topic, AddEntryCallback {
nsStats.replicatorCount += topicStats.remotePublishersStats.size();
replicators.forEach((cluster, replicator) -> {
// Update replicator cursor state
+ try {
((PersistentReplicator) replicator).updateCursorState();
+ } catch (Exception e) {
+ log.warn("[{}] Failed to update cursro state ", topic, e);
+ }
+
// Update replicator stats
ReplicatorStats rStat = replicator.getStats();
