DBZ-2591 take last processed lsn from topic rather than from db register table
This commit is contained in:
parent
6972dab987
commit
77279a1c5b
@ -164,10 +164,9 @@ public void getChangesForTables(Db2ChangeTable[] changeTables, Lsn intervalFromL
|
|||||||
queries[idx] = query;
|
queries[idx] = query;
|
||||||
// If the table was added in the middle of queried buffer we need
|
// If the table was added in the middle of queried buffer we need
|
||||||
// to adjust from to the first LSN available
|
// to adjust from to the first LSN available
|
||||||
final Lsn fromLsn = changeTable.getStartLsn().compareTo(intervalFromLsn) > 0 ? changeTable.getStartLsn() : intervalFromLsn;
|
LOGGER.trace("Getting changes for table {} in range[{}, {}]", changeTable, intervalFromLsn, intervalToLsn);
|
||||||
LOGGER.trace("Getting changes for table {} in range[{}, {}]", changeTable, fromLsn, intervalToLsn);
|
|
||||||
preparers[idx] = statement -> {
|
preparers[idx] = statement -> {
|
||||||
statement.setBytes(1, fromLsn.getBinary());
|
statement.setBytes(1, intervalFromLsn.getBinary());
|
||||||
statement.setBytes(2, intervalToLsn.getBinary());
|
statement.setBytes(2, intervalToLsn.getBinary());
|
||||||
|
|
||||||
};
|
};
|
||||||
|
Loading…
Reference in New Issue
Block a user