[CDCSDK] CDC + XCluster Test Failing with Row Mismatch in Target Universe

[ShikharSahay]

Jira Link: DB-14895

Description

The test for CDC + XCluster replication on version 2024.2.1.0-b141 is failing with the error:
AssertionError: Time is ended and replication via xCluster didn't happen test_cdc_8ef094 yb=138077 sink=180414

While replication via CDC completes successfully, there is a discrepancy between the source and target universes. The target universe contains more rows than the source universe

Source connector version

quay.io/yugabyte/debezium-connector:dz.1.9.5.yb.grpc.2024.1

Connector configuration

add connector connector_name='ybconnector_cdc_cbb3d2_test_cdc_040829' stream_id='7a286e819b1e3899d142f9a353908be2' db_name='cdc_cbb3d2' connector_host='172.151.24.98' table_list=['test_cdc_040829'] {'name': 'ybconnector_cdc_cbb3d2_test_cdc_040829', 'config': {'database.master.addresses': '172.151.28.144:7100,172.151.18.159:7100,172.151.22.213:7100', 'database.hostname': '172.151.28.144:5433,172.151.18.159:5433,172.151.22.213:5433', 'database.port': 5433, 'database.masterhost': '172.151.22.213', 'database.masterport': '7100', 'database.user': 'yugabyte', 'database.password': 'yugabyte', 'database.dbname': 'cdc_cbb3d2', 'snapshot.mode': 'initial', 'admin.operation.timeout.ms': 600000, 'socket.read.timeout.ms': 300000, 'max.connector.retries': '10', 'operation.timeout.ms': 600000, 'topic.creation.default.compression.type': 'lz4', 'topic.creation.default.cleanup.policy': 'delete', 'topic.creation.default.partitions': 2, 'topic.creation.default.replication.factor': '1', 'tasks.max': '5', 'connector.class': 'io.debezium.connector.yugabytedb.YugabyteDBgRPCConnector', 'database.server.name': 'ybconnector_cdc_cbb3d2_test_cdc_040829', 'database.streamid': '7a286e819b1e3899d142f9a353908be2', 'table.include.list': 'public.test_cdc_040829'}}

YugabyteDB version

2024.2.1.0-b141

Issue Type

kind/bug

Warning: Please confirm that this issue does not contain any sensitive information

• I confirm this issue does not contain any sensitive information.