diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSourceMetrics.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSourceMetrics.java index f9253f84a..d8be83e98 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSourceMetrics.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSourceMetrics.java @@ -11,6 +11,7 @@ import java.time.Instant; import java.time.OffsetDateTime; import java.time.ZoneOffset; +import java.util.Arrays; import java.util.Map; import java.util.Objects; import java.util.Set; @@ -693,8 +694,8 @@ public String toString() { ", commitScn=" + commitScn + ", oldestScn=" + oldestScn + ", oldestScnTime=" + oldestScnTime + - ", currentLogFileNames=" + currentLogFileNames + - ", redoLogStatuses=" + redoLogStatuses + + ", currentLogFileNames=" + Arrays.asList(currentLogFileNames.get()) + + ", redoLogStatuses=" + Arrays.asList(redoLogStatuses.get()) + ", databaseZoneOffset=" + databaseZoneOffset + ", batchSize=" + batchSize + ", logSwitchCount=" + logSwitchCount + @@ -721,7 +722,7 @@ public String toString() { ", processGlobalAreaMemory=" + processGlobalAreaMemory + ", abandonedTransactionIds=" + abandonedTransactionIds + ", rolledBackTransactionIds=" + rolledBackTransactionIds + - "} " + super.toString(); + "} "; } /** @@ -780,6 +781,11 @@ Duration getLast() { Duration getTotal() { return total.get(); } + + @Override + public String toString() { + return String.format("{min=%s,max=%s,total=%s}", min.get(), max.get(), total.get()); + } } /** @@ -820,6 +826,11 @@ public long getValue() { public long getMax() { return max.get(); } + + @Override + public String toString() { + return String.format("{value=%d,max=%d}", value.get(), max.get()); + } } /** @@ -849,6 +860,11 @@ public void add(T value) { public Set getAll() { return this.cache.get().keySet(); } + + @Override + public String toString() { + return getAll().toString(); + } } }