This is an automated email from the ASF dual-hosted git repository.

petrov-mg pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git


The following commit(s) were added to refs/heads/master by this push:
     new 88d7f8d4 IGNITE-28740 Refactored Ignite product version initialization 
and usages (#354)
88d7f8d4 is described below

commit 88d7f8d49fd5bc8ee50ca0994dc8534fc941f3b1
Author: Mikhail Petrov <[email protected]>
AuthorDate: Thu Jun 4 12:19:24 2026 +0300

    IGNITE-28740 Refactored Ignite product version initialization and usages 
(#354)
---
 .../org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java | 4 ++--
 .../org/apache/ignite/cdc/kafka/KafkaToIgniteCommandLineStartup.java  | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java
 
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java
index 5332f1bd..7b14ca65 100644
--- 
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java
+++ 
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/AbstractKafkaToIgniteCdcStreamer.java
@@ -42,8 +42,8 @@ import 
org.apache.kafka.common.serialization.IntegerDeserializer;
 
 import static org.apache.ignite.internal.IgniteKernal.NL;
 import static org.apache.ignite.internal.IgniteKernal.SITE;
-import static org.apache.ignite.internal.IgniteVersionUtils.ACK_VER_STR;
 import static org.apache.ignite.internal.IgniteVersionUtils.COPYRIGHT;
+import static org.apache.ignite.internal.IgniteVersionUtils.VER;
 import static 
org.apache.kafka.clients.consumer.ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG;
 import static 
org.apache.kafka.clients.consumer.ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG;
 
@@ -254,7 +254,7 @@ abstract class AbstractKafkaToIgniteCdcStreamer implements 
Runnable {
 
     /** */
     private void ackAsciiLogo(IgniteLogger log) {
-        String ver = "ver. " + ACK_VER_STR;
+        String ver = "ver. " + VER;
 
         if (log.isInfoEnabled()) {
             log.info(NL + NL +
diff --git 
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCommandLineStartup.java
 
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCommandLineStartup.java
index f14aad87..0ac63269 100644
--- 
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCommandLineStartup.java
+++ 
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCommandLineStartup.java
@@ -22,8 +22,8 @@ import org.apache.ignite.internal.util.typedef.X;
 import org.jetbrains.annotations.Nullable;
 
 import static org.apache.ignite.cdc.kafka.KafkaToIgniteLoader.KAFKA_PROPERTIES;
-import static org.apache.ignite.internal.IgniteVersionUtils.ACK_VER_STR;
 import static org.apache.ignite.internal.IgniteVersionUtils.COPYRIGHT;
+import static org.apache.ignite.internal.IgniteVersionUtils.VER;
 import static org.apache.ignite.startup.cmdline.CommandLineStartup.isHelp;
 
 /**
@@ -45,7 +45,7 @@ public class KafkaToIgniteCommandLineStartup {
      */
     public static void main(String[] args) {
         if (!QUITE) {
-            X.println("Kafka To Ignite Command Line Startup, ver. " + 
ACK_VER_STR);
+            X.println("Kafka To Ignite Command Line Startup, ver. " + VER);
             X.println(COPYRIGHT);
             X.println();
         }

Reply via email to