alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-6204 Fix typo

Browse Source 
Co-authored-by: Jiri Pechanec <jpechane@redhat.com>
This commit is contained in:
Vojtěch Juránek 2023-03-14 16:33:08 +01:00 committed by Jiri Pechanec
parent 3b5740f1a8
commit 42b374613a
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/WalPositionLocator.java
View File

@ -77,7 +77,7 @@ public Optional<Lsn> 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);