From aab7d20f8c700b869c08da7dbabb570e8cbbb31e Mon Sep 17 00:00:00 2001
From: Maksim Davydov <davydov.mm17@physics.msu.ru>
Date: Wed, 28 May 2025 18:26:01 +0300
Subject: [PATCH] IGNITE-25244 Make BinaryTypeImpl package private

---
 .../org/apache/ignite/cdc/AbstractIgniteCdcStreamer.java | 4 ++--
 .../ignite/cdc/kafka/IgniteToKafkaCdcStreamer.java       | 9 +++++++--
 2 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/AbstractIgniteCdcStreamer.java b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/AbstractIgniteCdcStreamer.java
index f56a9954e..e48098245 100644
--- a/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/AbstractIgniteCdcStreamer.java
+++ b/modules/cdc-ext/src/main/java/org/apache/ignite/cdc/AbstractIgniteCdcStreamer.java
@@ -26,7 +26,7 @@
 import org.apache.ignite.binary.BinaryType;
 import org.apache.ignite.internal.binary.BinaryContext;
 import org.apache.ignite.internal.binary.BinaryMetadata;
-import org.apache.ignite.internal.binary.BinaryTypeImpl;
+import org.apache.ignite.internal.binary.BinaryUtils;
 import org.apache.ignite.internal.processors.metric.MetricRegistryImpl;
 import org.apache.ignite.internal.processors.metric.impl.AtomicLongMetric;
 import org.apache.ignite.internal.util.typedef.F;
@@ -169,7 +169,7 @@ public abstract class AbstractIgniteCdcStreamer implements CdcConsumer {
     /** {@inheritDoc} */
     @Override public void onTypes(Iterator<BinaryType> types) {
         types.forEachRemaining(t -> {
-            BinaryMetadata meta = ((BinaryTypeImpl)t).metadata();
+            BinaryMetadata meta = BinaryUtils.binaryMetadataFromType(t);
 
             registerBinaryMeta(binaryContext(), log, meta);
 
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 08fa25a07..493161b24 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
@@ -37,7 +37,7 @@
 import org.apache.ignite.cdc.CdcEvent;
 import org.apache.ignite.cdc.TypeMapping;
 import org.apache.ignite.cdc.conflictresolve.CacheVersionConflictResolverImpl;
-import org.apache.ignite.internal.binary.BinaryTypeImpl;
+import org.apache.ignite.internal.binary.BinaryUtils;
 import org.apache.ignite.internal.cdc.CdcMain;
 import org.apache.ignite.internal.processors.metric.MetricRegistryImpl;
 import org.apache.ignite.internal.processors.metric.impl.AtomicLongMetric;
@@ -225,7 +225,12 @@ public class IgniteToKafkaCdcStreamer implements CdcConsumer {
     @Override public void onTypes(Iterator<BinaryType> types) {
         sendAll(
             types,
-            t -> new ProducerRecord<>(metadataTopic, 0, null, IgniteUtils.toBytes(((BinaryTypeImpl)t).metadata())),
+            t -> new ProducerRecord<>(
+                metadataTopic,
+                0,
+                null,
+                IgniteUtils.toBytes(BinaryUtils.binaryMetadataFromType(t))
+            ),
             typesCnt
         );