diff --git a/modules/control-utility/src/test/java/org/apache/ignite/util/CdcResendCommandTest.java b/modules/control-utility/src/test/java/org/apache/ignite/util/CdcResendCommandTest.java index e6d6f078355b45..bd8c93f327a4f9 100644 --- a/modules/control-utility/src/test/java/org/apache/ignite/util/CdcResendCommandTest.java +++ b/modules/control-utility/src/test/java/org/apache/ignite/util/CdcResendCommandTest.java @@ -182,18 +182,18 @@ public void testResendConflictVersion() throws Exception { assertTrue(GridTestUtils.waitForCondition(() -> cnsmr.events().size() == 3, 10_000, 100)); CdcEvent ev0 = cnsmr.events().get(0); - assertEquals(0, ev0.key()); - assertEquals(0, ev0.value()); + assertEquals(0, ev0.unwrappedKey()); + assertEquals(0, ev0.unwrappedValue()); assertNull(ev0.version().otherClusterVersion()); CdcEvent ev1 = cnsmr.events().get(1); - assertEquals(0, ev1.key()); - assertEquals(1, ev1.value()); + assertEquals(0, ev1.unwrappedKey()); + assertEquals(1, ev1.unwrappedValue()); assertEquals(conflict, ev1.version().otherClusterVersion()); CdcEvent ev2 = cnsmr.events().get(2); - assertEquals(0, ev2.key()); - assertEquals(1, ev2.value()); + assertEquals(0, ev2.unwrappedKey()); + assertEquals(1, ev2.unwrappedValue()); assertNull(ev2.version().otherClusterVersion()); }