diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/ServerInfo.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/ServerInfo.java index 3ab8a1c..6412dd2 100644 --- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/ServerInfo.java +++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/ServerInfo.java @@ -197,7 +197,7 @@ protected SlotState asSlotState() { @Override public String toString() { - return "ReplicationSlot [active=" + active + ", latestFlushedLsn=" + latestFlushedLsn + ", catalogXmin=" + catalogXmin + "]"; + return "ReplicationSlot [active=" + active + ", latestFlushedLsn=" + latestFlushedLsn + ", restartLsn=" + restartLsn + ", catalogXmin=" + catalogXmin + "]"; } } } diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/WalPositionLocator.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/WalPositionLocator.java index 067b587..489b13c 100644 --- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/WalPositionLocator.java +++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/WalPositionLocator.java @@ -139,8 +139,8 @@ public boolean skipMessage(Lsn lsn) { } if (startStreamingLsn.compareTo(lsn) < 0) { throw new DebeziumException(String.format( - "Message with LSN '%s' larger than expected LSN '%s'. This is unexpected and can lead to an infinite loop or a data loss.", - lsn, startStreamingLsn)); + "Message with LSN '%s' larger than expected LSN '%s'. This is unexpected and can lead to an infinite loop or a data loss: %s", + lsn, startStreamingLsn, this)); } LOGGER.debug("Message with LSN '{}' filtered", lsn); return true;