diff --git a/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2Connection.java b/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2Connection.java
index e0cedfdcd..8e4654d19 100644
--- a/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2Connection.java
+++ b/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2Connection.java
@@ -164,10 +164,9 @@ public void getChangesForTables(Db2ChangeTable[] changeTables, Lsn intervalFromL
             queries[idx] = query;
             // If the table was added in the middle of queried buffer we need
             // 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, fromLsn, intervalToLsn);
+            LOGGER.trace("Getting changes for table {} in range[{}, {}]", changeTable, intervalFromLsn, intervalToLsn);
             preparers[idx] = statement -> {
-                statement.setBytes(1, fromLsn.getBinary());
+                statement.setBytes(1, intervalFromLsn.getBinary());
                 statement.setBytes(2, intervalToLsn.getBinary());
 
             };