This is an automated email from the ASF dual-hosted git repository.
timoninmaxim 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 4a346cb2 IGNITE-23333 СDC is no longer experimental (#290)
4a346cb2 is described below
commit 4a346cb2b45035e1793af60bd428a37aac0b104b
Author: Alexander <[email protected]>
AuthorDate: Fri Feb 7 11:01:19 2025 +0300
IGNITE-23333 СDC is no longer experimental (#290)
---
.../src/main/java/org/apache/ignite/cdc/IgniteToIgniteCdcStreamer.java | 2 --
.../main/java/org/apache/ignite/cdc/kafka/IgniteToKafkaCdcStreamer.java | 2 --
.../main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamer.java | 2 --
.../apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamerConfiguration.java | 2 --
.../org/apache/ignite/cdc/kafka/KafkaToIgniteClientCdcStreamer.java | 2 --
5 files changed, 10 deletions(-)
diff --git
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/IgniteToIgniteCdcStreamer.java
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/IgniteToIgniteCdcStreamer.java
index 618c61d7..d38f4588 100644
---
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/IgniteToIgniteCdcStreamer.java
+++
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/IgniteToIgniteCdcStreamer.java
@@ -27,7 +27,6 @@ import org.apache.ignite.internal.binary.BinaryContext;
import org.apache.ignite.internal.cdc.CdcMain;
import
org.apache.ignite.internal.processors.cache.binary.CacheObjectBinaryProcessorImpl;
import org.apache.ignite.internal.util.typedef.internal.A;
-import org.apache.ignite.lang.IgniteExperimental;
import org.apache.ignite.lifecycle.LifecycleBean;
import org.apache.ignite.lifecycle.LifecycleEventType;
import org.apache.ignite.metric.MetricRegistry;
@@ -49,7 +48,6 @@ import static
org.apache.ignite.lifecycle.LifecycleEventType.BEFORE_NODE_STOP;
* @see CdcMain
* @see CacheVersionConflictResolverImpl
*/
-@IgniteExperimental
public class IgniteToIgniteCdcStreamer extends AbstractIgniteCdcStreamer
implements LifecycleBean {
/** Destination cluster client configuration. */
private IgniteConfiguration destIgniteCfg;
diff --git
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/IgniteToKafkaCdcStreamer.java
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/IgniteToKafkaCdcStreamer.java
index db1ffa49..08fa25a0 100644
---
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/IgniteToKafkaCdcStreamer.java
+++
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/IgniteToKafkaCdcStreamer.java
@@ -46,7 +46,6 @@ import org.apache.ignite.internal.util.typedef.F;
import org.apache.ignite.internal.util.typedef.internal.A;
import org.apache.ignite.internal.util.typedef.internal.CU;
import org.apache.ignite.internal.util.typedef.internal.U;
-import org.apache.ignite.lang.IgniteExperimental;
import org.apache.ignite.metric.MetricRegistry;
import org.apache.ignite.resources.LoggerResource;
import org.apache.kafka.clients.producer.KafkaProducer;
@@ -77,7 +76,6 @@ import static
org.apache.kafka.clients.producer.ProducerConfig.VALUE_SERIALIZER_
* @see KafkaToIgniteClientCdcStreamer
* @see CacheVersionConflictResolverImpl
*/
-@IgniteExperimental
public class IgniteToKafkaCdcStreamer implements CdcConsumer {
/** */
public static final String EVTS_SENT_CNT = "EventsCount";
diff --git
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamer.java
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamer.java
index 3386a4c0..0e2ada72 100644
---
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamer.java
+++
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamer.java
@@ -33,7 +33,6 @@ import org.apache.ignite.internal.cdc.CdcMain;
import
org.apache.ignite.internal.processors.cache.binary.CacheObjectBinaryProcessorImpl;
import org.apache.ignite.internal.util.typedef.internal.A;
import org.apache.ignite.internal.util.typedef.internal.U;
-import org.apache.ignite.lang.IgniteExperimental;
/**
* Main class of Kafka to Ignite application.
@@ -68,7 +67,6 @@ import org.apache.ignite.lang.IgniteExperimental;
* @see KafkaToIgniteCdcStreamerApplier
* @see CacheConflictResolutionManagerImpl
*/
-@IgniteExperimental
public class KafkaToIgniteCdcStreamer extends AbstractKafkaToIgniteCdcStreamer
{
/** Ignite configuration. */
private final IgniteConfiguration igniteCfg;
diff --git
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamerConfiguration.java
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamerConfiguration.java
index 07b97e2b..571afac8 100644
---
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamerConfiguration.java
+++
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteCdcStreamerConfiguration.java
@@ -21,7 +21,6 @@ import java.util.Collection;
import java.util.Map;
import org.apache.ignite.cdc.CdcConfiguration;
import org.apache.ignite.internal.processors.cache.IgniteInternalCache;
-import org.apache.ignite.lang.IgniteExperimental;
import org.apache.ignite.spi.metric.MetricExporterSpi;
import org.apache.ignite.spi.metric.jmx.JmxMetricExporterSpi;
@@ -31,7 +30,6 @@ import org.apache.ignite.spi.metric.jmx.JmxMetricExporterSpi;
* @see KafkaToIgniteCdcStreamer
* @see KafkaToIgniteLoader
*/
-@IgniteExperimental
public class KafkaToIgniteCdcStreamerConfiguration {
/** Default maximum time to complete Kafka related requests, in
milliseconds. */
public static final long DFLT_KAFKA_REQ_TIMEOUT = 3_000L;
diff --git
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteClientCdcStreamer.java
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteClientCdcStreamer.java
index 6d05aab7..706d53ad 100644
---
a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteClientCdcStreamer.java
+++
b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/KafkaToIgniteClientCdcStreamer.java
@@ -34,7 +34,6 @@ import org.apache.ignite.internal.cdc.CdcMain;
import org.apache.ignite.internal.client.thin.ClientBinary;
import org.apache.ignite.internal.util.typedef.internal.A;
import org.apache.ignite.internal.util.typedef.internal.U;
-import org.apache.ignite.lang.IgniteExperimental;
/**
* Main class of Kafka to Ignite application.
@@ -70,7 +69,6 @@ import org.apache.ignite.lang.IgniteExperimental;
* @see KafkaToIgniteCdcStreamerApplier
* @see CacheConflictResolutionManagerImpl
*/
-@IgniteExperimental
public class KafkaToIgniteClientCdcStreamer extends
AbstractKafkaToIgniteCdcStreamer {
/** Ignite thin client configuration. */
private final ClientConfiguration clientCfg;
