WIP

Author: anton-vinogradov

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

@@ -84,12 +84,12 @@ public CdcEventsIgniteApplier(IgniteEx ignite, int maxBatchSize, IgniteLogger lo
 
     /** {@inheritDoc} */
     @Override protected KeyCacheObject toKey(CdcEvent evt) {
-        return evt.key();
+        return evt.keyCacheObject();
     }
 
     /** {@inheritDoc} */
     @Override protected GridCacheDrInfo toValue(int cacheId, CdcEvent evt, GridCacheVersion ver) {
-        CacheObject val = evt.value();
+        CacheObject val = evt.valueCacheObject();
 
         return evt.expireTime() != EXPIRE_TIME_ETERNAL ?
             new GridCacheDrExpirationInfo(val, ver, TTL_ETERNAL, evt.expireTime()) :

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

@@ -55,12 +55,12 @@ public CdcEventsIgniteClientApplier(IgniteClient client, int maxBatchSize, Ignit
 
     /** {@inheritDoc} */
     @Override protected Object toKey(CdcEvent evt) {
-        return evt.unwrappedKey();
+        return evt.key();
     }
 
     /** {@inheritDoc} */
     @Override protected T3<Object, GridCacheVersion, Long> toValue(int cacheId, CdcEvent evt, GridCacheVersion ver) {
-        return new T3<>(evt.unwrappedValue(), ver, evt.expireTime());
+        return new T3<>(evt.value(), ver, evt.expireTime());
     }
 
     /** {@inheritDoc} */