Minor improve metrics logging

memiiso · Sep 17, 2021 · a69967c · a69967c
1 parent 8d9dbb0
commit a69967c
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 2 deletions.
diff --git a/debezium-server-batch-sinks/src/main/java/io/debezium/server/batch/DebeziumMetrics.java b/debezium-server-batch-sinks/src/main/java/io/debezium/server/batch/DebeziumMetrics.java
@@ -89,4 +89,14 @@ public long streamingMilliSecondsBehindSource() {
     }
   }
 
+  public void logMetrics() {
+    LOGGER.info("Debezium Metrics:" +
+        " snapshotCompleted=" + this.snapshotCompleted() +
+        " snapshotRunning=" + this.snapshotRunning() +
+        " streamingQueueCurrentSize=" + this.streamingQueueCurrentSize() +
+        " streamingQueueRemainingCapacity=" + this.streamingQueueRemainingCapacity() +
+        " maxQueueSize=" + this.maxQueueSize +
+        " streamingMilliSecondsBehindSource=" + this.streamingMilliSecondsBehindSource()
+    );
+  }
 }
diff --git a/...er-batch-sinks/src/main/java/io/debezium/server/batch/batchsizewait/MaxBatchSizeWait.java b/...er-batch-sinks/src/main/java/io/debezium/server/batch/batchsizewait/MaxBatchSizeWait.java
@@ -67,8 +67,10 @@ public void waitMs(Integer numRecordsProcessed, Integer processingTimeMs) throws
     final int streamingSecondsBehindSource = (int) (debeziumMetrics.streamingMilliSecondsBehindSource() / 1000);
     final boolean snapshotCompleted = debeziumMetrics.snapshotCompleted();
 
-    LOGGER.debug("Processed {}, QueueCurrentSize:{}, QueueTotalCapacity:{}, SecondsBehindSource:{}, SnapshotCompleted:{}",
-        numRecordsProcessed, streamingQueueCurrentSize, maxQueueSize, streamingSecondsBehindSource, snapshotCompleted
+    LOGGER.debug("Processed {}, QueueCurrentSize:{}, QueueTotalCapacity:{}, SecondsBehindSource:{}, " +
+            "SnapshotCompleted:{}, snapshotRunning:{}",
+        numRecordsProcessed, streamingQueueCurrentSize, maxQueueSize, streamingSecondsBehindSource, snapshotCompleted,
+        debeziumMetrics.snapshotRunning()
     );
 
     int totalWaitMs = 0;