Merge pull request #408 from Altinity/sink-connector-client-integrati…

…on-tests Change rest api parameter for binlog_position to match client
Altinity · Dec 11, 2023 · 2c8a88c · 2c8a88c
2 parents 8b1c68a + bc125e5
commit 2c8a88c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ht/src/main/java/com/altinity/clickhouse/debezium/embedded/cdc/DebeziumOffsetStorage.java b/...ht/src/main/java/com/altinity/clickhouse/debezium/embedded/cdc/DebeziumOffsetStorage.java
@@ -16,7 +16,7 @@
 public class DebeziumOffsetStorage {
 
     // MySQL parameters
-    public static final String BINLOG_POS = "binlog_pos";
+    public static final String BINLOG_POS = "binlog_position";
     public static final String BINLOG_FILE = "binlog_file";
 
     public static final String GTID = "gtid";