From e21aae1d69aa296363fc88544473a0273157abc9 Mon Sep 17 00:00:00 2001
From: Kanthi Subramanian <subkanthi@gmail.com>
Date: Mon, 6 May 2024 17:52:16 -0400
Subject: [PATCH] Force RMT to old version for Integration tests

---
 .../embedded/ddl/parser/MySqlDDLParserListenerImplTest.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/MySqlDDLParserListenerImplTest.java b/sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/MySqlDDLParserListenerImplTest.java
index d49e32a95..9a25d9792 100644
--- a/sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/MySqlDDLParserListenerImplTest.java
+++ b/sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/MySqlDDLParserListenerImplTest.java
@@ -1,5 +1,6 @@
 package com.altinity.clickhouse.debezium.embedded.ddl.parser;
 
+import com.altinity.clickhouse.debezium.embedded.cdc.DebeziumChangeEventCapture;
 import com.altinity.clickhouse.sink.connector.ClickHouseSinkConnectorConfig;
 import com.altinity.clickhouse.sink.connector.ClickHouseSinkConnectorConfigVariables;
 import org.apache.logging.log4j.LogManager;
@@ -24,6 +25,7 @@ public class MySqlDDLParserListenerImplTest {
     static public void init() {
         mySQLDDLParserService = new MySQLDDLParserService(new ClickHouseSinkConnectorConfig(new HashMap<>()),
                 "employees");
+        DebeziumChangeEventCapture.isNewReplacingMergeTreeEngine = true;
     }
     @Test
     public void testCreateTableWithEnum() {