DBZ-8557: Account for API changes in ChangeTableResultSet

debezium · Jan 16, 2025 · f8aaa15 · f8aaa15
1 parent 4775bad
commit f8aaa15
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/main/java/io/debezium/connector/db2/Db2StreamingChangeEventSource.java b/src/main/java/io/debezium/connector/db2/Db2StreamingChangeEventSource.java
@@ -390,9 +390,16 @@ private Db2ChangeTable[] getCdcTablesToQuery(Db2Partition partition, Db2OffsetCo
      *
      */
     private static class ChangeTablePointer extends ChangeTableResultSet<Db2ChangeTable, TxLogPosition> {
+        private final ResultSet resultSet;
 
         ChangeTablePointer(Db2ChangeTable changeTable, ResultSet resultSet) {
-            super(changeTable, resultSet, COL_DATA);
+            super(changeTable, COL_DATA, 0);
+            this.resultSet = resultSet;
+        }
+
+        @Override
+        protected ResultSet getNextResultSet(TxLogPosition txLogPosition) throws SQLException {
+            return resultSet;
         }
 
         @Override