[jira] [Commented] (IGNITE-14449) Add binary meta change event to CDCCosumer

["Nikolay Izhikov (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/IGNITE-14449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370691#comment-17370691 ] 

Nikolay Izhikov commented on IGNITE-14449:
------------------------------------------

{code:java}

    /** Active/Passive mode means changes made only in one cluster. */
    @Test
    public void testActivePassiveSqlDataReplication() throws Exception {
        String createTbl = "CREATE TABLE T1(ID BIGINT PRIMARY KEY, NAME VARCHAR)";
        String insertQry = "INSERT INTO T1 VALUES(?, ?)";

        executeSql(srcCluster[0], createTbl);
        executeSql(destCluster[0], createTbl);
        executeSql(destCluster[0], insertQry, 1, "Name1");

        List<IgniteInternalFuture<?>> futs = startActivePassiveCdc("SQL_PUBLIC_T1");

        try {
            IntStream.range(1, KEYS_CNT).forEach(id -> executeSql(srcCluster[0], insertQry, id, "Name" + id));

            assertTrue(waitForCondition(() -> {
                long cnt = (Long)executeSql(destCluster[0], "SELECT COUNT(*) FROM T1").get(0).get(0);

                return KEYS_CNT == cnt;
            }, getTestTimeout()));
        }
        finally {
            for (IgniteInternalFuture<?> fut : futs)
                fut.cancel();
        }
    }
{code}

> Add binary meta change event to CDCCosumer
> ------------------------------------------
>
>                 Key: IGNITE-14449
>                 URL: https://issues.apache.org/jira/browse/IGNITE-14449
>             Project: Ignite
>          Issue Type: Improvement
>            Reporter: Nikolay Izhikov
>            Priority: Major
>              Labels: IEP-59
>
> Need to provide the way to notify {{CDCConsumer}} about changes in binary meta.
> Required to correctly notify subsequent systems about new types that can be found in change events.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)