From 42b374613ad0ecf6afab60885ea7b2aa4a858577 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Vojt=C4=9Bch=20Jur=C3=A1nek?= Date: Tue, 14 Mar 2023 16:33:08 +0100 Subject: [PATCH] DBZ-6204 Fix typo Co-authored-by: Jiri Pechanec --- .../connector/postgresql/connection/WalPositionLocator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 9403ab15e..9d9cb4fa6 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 @@ -77,7 +77,7 @@ public Optional resumeFromLsn(Lsn currentLsn, ReplicationMessage message) { // BEGIN and first message after change have the same LSN if (txStartLsn != null && (lastProcessedMessageType == null || lastProcessedMessageType == Operation.BEGIN || lastProcessedMessageType == Operation.COMMIT)) { - // start from the BEGIN tx; prevent skipping of unprocessed event after BEGIN or previsou tx COMMIT + // start from the BEGIN tx; prevent skipping of unprocessed event after BEGIN or previous tx COMMIT LOGGER.info("Will restart from LSN '{}' corresponding to the event following the BEGIN event", txStartLsn); startStreamingLsn = txStartLsn; return Optional.of(startStreamingLsn);