From dc5b496c28fb0fe69cb16bcf606d23e51588e945 Mon Sep 17 00:00:00 2001 From: Chris Cranford Date: Fri, 29 Mar 2024 07:50:38 -0400 Subject: [PATCH] DBZ-7693 Correctly enable row-query events --- .../debezium/connector/binlog/BinlogIncrementalSnapshotIT.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogIncrementalSnapshotIT.java b/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogIncrementalSnapshotIT.java index 012f881fb..3ebce586c 100644 --- a/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogIncrementalSnapshotIT.java +++ b/debezium-connector-binlog/src/test/java/io/debezium/connector/binlog/BinlogIncrementalSnapshotIT.java @@ -256,7 +256,7 @@ public void updates() throws Exception { final int batchSize = 10; try (JdbcConnection connection = databaseConnection()) { connection.setAutoCommit(false); - ((BinlogTestConnection) connection).setBinlogCompressionOn(); + ((BinlogTestConnection) connection).setBinlogRowQueryEventsOn(); for (int i = 0; i < ROW_COUNT; i++) { connection.executeWithoutCommitting( String.format("UPDATE %s SET aa = aa + 2000 WHERE pk > %s AND pk <= %s", tableName(),