IGNITE-18372

* CdcKafkaReplicationAppsTest fix
apache · Jul 8, 2024 · c1d7ada · c1d7ada
1 parent 220bcf2
commit c1d7ada
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 0 deletions.
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
@@ -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
@@ -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
@@ -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}" />