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

DBZ-2582-lsn-changes revert log change

Browse Source
This commit is contained in:
James Gormley 2020-09-28 06:36:46 -04:00 committed by Gunnar Morling
parent 4637425598
commit 6d68bb02de
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerStreamingChangeEventSource.java
View File

@ -135,9 +135,7 @@ public void execute(ChangeEventSourceContext context) throws InterruptedExceptio
}
// There is no change in the database
if (maxLsnResult.getMaxTransactionalLsn().compareTo(lastProcessedPosition.getCommitLsn()) <= 0 && shouldIncreaseFromLsn) {
LOGGER.debug("No change in the database. Max Transaction Lsn: {}, Max Lsn: {}, Last Processed Position: {}.",
maxLsnResult.getMaxTransactionalLsn(), maxLsnResult.getMaxLsn(), lastProcessedPosition.getCommitLsn());
lastProcessedPosition = TxLogPosition.valueOf(maxLsnResult.getMaxLsn());
LOGGER.debug("No change in the database");
continue;
}