IGNITE-22530 Add CdcConsumerEx interface

Author: Andrei Nadyktov

modules/cdc-ext/src/main/java/org/apache/ignite/cdc/AbstractIgniteCdcStreamer.java

@@ -53,7 +53,7 @@
  *
  * @see AbstractCdcEventsApplier
  */
-public abstract class AbstractIgniteCdcStreamer implements CdcConsumer {
+public abstract class AbstractIgniteCdcStreamer implements CdcConsumerEx {
     /** */
     public static final String EVTS_SENT_CNT = "EventsCount";
 
@@ -130,6 +130,11 @@ public abstract class AbstractIgniteCdcStreamer implements CdcConsumer {
     @LoggerResource
     protected IgniteLogger log;
 
+    /** {@inheritDoc} */
+    @Override public void start(MetricRegistry reg) {
+        //No-op
+    }
+
     /** {@inheritDoc} */
     @Override public void start(MetricRegistry reg, Path cdcDir) {
         A.notEmpty(caches, "caches");

modules/cdc-ext/src/main/java/org/apache/ignite/cdc/kafka/IgniteToKafkaCdcStreamer.java

@@ -42,7 +42,7 @@
 import org.apache.ignite.IgniteLogger;
 import org.apache.ignite.binary.BinaryType;
 import org.apache.ignite.cdc.CdcCacheEvent;
-import org.apache.ignite.cdc.CdcConsumer;
+import org.apache.ignite.cdc.CdcConsumerEx;
 import org.apache.ignite.cdc.CdcEvent;
 import org.apache.ignite.cdc.TypeMapping;
 import org.apache.ignite.cdc.conflictresolve.CacheVersionConflictResolverImpl;
@@ -87,7 +87,7 @@
  * @see KafkaToIgniteClientCdcStreamer
  * @see CacheVersionConflictResolverImpl
  */
-public class IgniteToKafkaCdcStreamer implements CdcConsumer {
+public class IgniteToKafkaCdcStreamer implements CdcConsumerEx {
     /** */
     public static final String EVTS_SENT_CNT = "EventsCount";
 
@@ -376,6 +376,11 @@ private <T> void sendOneBatch(
         }
     }
 
+    /** {@inheritDoc} */
+    @Override public void start(MetricRegistry reg) {
+        //No-op
+    }
+
     /** {@inheritDoc} */
     @Override public void start(MetricRegistry reg, Path cdcDir) {
         A.notNull(kafkaProps, "Kafka properties");