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

DBZ-5031 Stop skipping message if last received lsn is higher or equal to the startStreamingLsn in WalPositionLocation

Browse Source
This commit is contained in:
Jun Zhao 2022-06-16 14:44:19 -07:00 committed by Jiri Pechanec
parent 44107961e5
commit 29fbdc03bf
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

@ -130,7 +130,7 @@ public boolean skipMessage(Lsn lsn) {
if (passMessages) {
return false;
}
if (startStreamingLsn == null || startStreamingLsn.equals(lsn)) {
if (startStreamingLsn == null || startStreamingLsn.compareTo(lsn) <= 0) {
LOGGER.info("Message with LSN '{}' arrived, switching off the filtering", lsn);
passMessages = true;
return false;