Cosmetic fixes

dragosvictor · Jun 25, 2024 · 157de7c · 157de7c
1 parent 9a9c35a
commit 157de7c
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/OpenTelemetryReplicatorStats.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/OpenTelemetryReplicatorStats.java
@@ -159,10 +159,8 @@ private void recordMetricsForReplicator(AbstractReplicator replicator) {
         if (replicator instanceof PersistentReplicator persistentReplicator) {
             expiredCounter.record(persistentReplicator.getMessageExpiredCount(), attributes);
             backlogCounter.record(persistentReplicator.getNumberOfEntriesInBacklog(), attributes);
-        }
-
-        if (stats instanceof NonPersistentReplicatorStats nonPersistentStats) {
-            droppedCounter.record(nonPersistentStats.getMsgDropCount(), attributes);
+        } else if (replicator instanceof NonPersistentReplicator nonPersistentReplicator) {
+            droppedCounter.record(nonPersistentReplicator.getStats().getMsgDropCount(), attributes);
         }
     }
 }