Datax CDC 可靠 channel

DataX CDC（Change Data Capture）可靠性通过配置reliable channel来保证。当你使用可靠性通讯channel时，上游的任务会等待下游任务确认接收数据完成后才会继续发送下一批数据。这种方式可以保证数据的一致性和完整性，但是在性能上会有所下降。

在DataX的配置文件中，你需要设置core模块的transport channel类型为reliable，如下所示：

{
    "job": {
        "setting": {
            "speed": {
                "channel": 4
            },
            "errorLimit": {
                "record": 0,
                "percentage": 0.02
            }
        },
        "content": [
            {
                "reader": {
                    "name": "mysqlreader",
                    "parameter": {
                        "username": "your_username",
                        "password": "your_password",
                        "column": ["id", "name"],
                        "splitPk": "id",
                        "connection": [
                            {
                                "querySql": [
                                    "select id, name from your_table where ..."
                                ],
                                "jdbcUrl": [
                                    "jdbc:mysql://your_host:your_port/your_database"
                                ]
                            }
                        ]
                    }
                },
                "writer": {
                    "name": "mysqlwriter",
                    "parameter": {
                        "username": "your_username",
                        "password": "your_password",
                        "writeMode": "insert",
                        "connection": [
                            {
                                "jdbcUrl": "jdbc:mysql://your_host:your_port/your_database",
                                "table": ["your_table"]
                            }
                        ]
                    }
                }
            }
        ]
    }
}

在这个配置中，setting 部分的 errorLimit 设置了错误容忍的策略，speed 部分的 channel 设置了使用的通道数量。

请注意，DataX的可靠性通信是在任务级别的，即同一个DataX任务的reader和writer端使用的是同一种通信机制。如果你需要在reader和writer之间实现可靠的数据传输，你可能需要在数据处理流程中加入额外的机制，比如事务或者两阶段提交协议。