Fix extract partitionId

singlestore-labs · Feb 21, 2024 · 2d8e380 · 2d8e380
1 parent e5247e9
commit 2d8e380
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/singlestore/debezium/util/ObserveResultSetUtils.java b/src/main/java/com/singlestore/debezium/util/ObserveResultSetUtils.java
@@ -43,7 +43,7 @@ public static String offset(ResultSet rs) throws SQLException {
     }
 
     public static Integer partitionId(ResultSet rs) throws SQLException {
-        return rs.getInt(METADATA_COLUMNS[1]) - 1;
+        return rs.getInt(METADATA_COLUMNS[1]);
     }
 
     private static String bytesToHex(byte[] bytes) {