From c1d7adad6135cd3b41ecabbe1e07d87f19586b42 Mon Sep 17 00:00:00 2001
From: Maksim Davydov <MMDavydov@sberbank.ru>
Date: Mon, 8 Jul 2024 18:03:25 +0300
Subject: [PATCH] IGNITE-18372 * CdcKafkaReplicationAppsTest fix

---
 .../apache/ignite/cdc/kafka/CdcKafkaReplicationAppsTest.java | 5 +++++
 .../test/resources/replication/kafka-to-ignite-client.xml    | 1 +
 .../src/test/resources/replication/kafka-to-ignite.xml       | 1 +
 3 files changed, 7 insertions(+)

diff --git a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/CdcKafkaReplicationAppsTest.java b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/CdcKafkaReplicationAppsTest.java
index 684360d97..96f1d242b 100644
--- a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/CdcKafkaReplicationAppsTest.java
+++ b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/CdcKafkaReplicationAppsTest.java
@@ -32,6 +32,7 @@
 import org.apache.ignite.startup.cmdline.CdcCommandLineStartup;
 
 import static org.apache.ignite.cdc.kafka.KafkaToIgniteCdcStreamerConfiguration.DFLT_KAFKA_REQ_TIMEOUT;
+import static org.apache.ignite.cdc.kafka.KafkaToIgniteCdcStreamerConfiguration.DFLT_METRICS_REG_NAME;
 import static org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi.DFLT_PORT_RANGE;
 import static org.apache.ignite.testframework.GridTestUtils.getFieldValue;
 import static org.apache.ignite.testframework.GridTestUtils.runAsync;
@@ -83,6 +84,9 @@ public class CdcKafkaReplicationAppsTest extends CdcKafkaReplicationTest {
     /** */
     public static final String HOST_ADDRESSES = "HOST_ADDRESSES";
 
+    /** */
+    public static final String METRIC_REG_NAME = "METRIC_REG_NAME";
+
     /** */
     private String kafkaPropsPath = null;
 
@@ -167,6 +171,7 @@ public class CdcKafkaReplicationAppsTest extends CdcKafkaReplicationTest {
         params.put(PARTS_TO, Integer.toString(partTo));
         params.put(THREAD_CNT, Integer.toString((partTo - partFrom) / 3));
         params.put(KAFKA_REQ_TIMEOUT, Long.toString(DFLT_KAFKA_REQ_TIMEOUT));
+        params.put(METRIC_REG_NAME, DFLT_METRICS_REG_NAME + "-" + igniteCfg.getIgniteInstanceName());
 
         return runAsync(
             () -> KafkaToIgniteCommandLineStartup.main(new String[] {prepareConfig(cfg, params)})
diff --git a/modules/cdc-ext/src/test/resources/replication/kafka-to-ignite-client.xml b/modules/cdc-ext/src/test/resources/replication/kafka-to-ignite-client.xml
index a676ef84e..91f977220 100644
--- a/modules/cdc-ext/src/test/resources/replication/kafka-to-ignite-client.xml
+++ b/modules/cdc-ext/src/test/resources/replication/kafka-to-ignite-client.xml
@@ -43,6 +43,7 @@
         <property name="kafkaPartsTo" value="{PARTS_TO}"/>
         <property name="threadCount" value="{THREAD_CNT}"/>
         <property name="kafkaRequestTimeout" value="{KAFKA_REQ_TIMEOUT}"/>
+        <property name="metricRegistryName" value="{METRIC_REG_NAME}"/>
     </bean>
 
     <util:properties id="kafkaProperties" location="{PROPS_PATH}" />
diff --git a/modules/cdc-ext/src/test/resources/replication/kafka-to-ignite.xml b/modules/cdc-ext/src/test/resources/replication/kafka-to-ignite.xml
index 3a59f88dc..c5d70e42e 100644
--- a/modules/cdc-ext/src/test/resources/replication/kafka-to-ignite.xml
+++ b/modules/cdc-ext/src/test/resources/replication/kafka-to-ignite.xml
@@ -57,6 +57,7 @@
         <property name="kafkaPartsTo" value="{PARTS_TO}"/>
         <property name="threadCount" value="{THREAD_CNT}"/>
         <property name="kafkaRequestTimeout" value="{KAFKA_REQ_TIMEOUT}"/>
+        <property name="metricRegistryName" value="{METRIC_REG_NAME}"/>
     </bean>
 
     <util:properties id="kafkaProperties" location="{PROPS_PATH}" />