KAFKA

zcbus_other 参数配置

{
    "keymap":{
        "loaderTime":"SEND_TIME",
        "send_type":"SEND_TYPE",
        "columntype":"COLUMN_TYPE", 
        "startTime":"START_TIME",
        "stopTime":"END_TIME",
        "optype":"OPERATION_TYPE",
        "db_type":"DB_TYPE",
        "op_time":"SEND_TIME",
        "db_name":"SCHEMA_NAME",
        "batch_id":"RECONCILIATION_ID",
        "table_name":"TABLE_NAME",
        "insert_count":"INSERT_COUNT",
        "update_count":"UPDATE_COUNT",
        "delete_count":"DELETE_COUNT",
        "ddl_count":"DDL_COUNT", 
        "schema_name":"SCHEMA_NAME", 
        "before":"BEFORE",
        "after":"AFTER",
        "primarykey":"PRIMARY_KEY",
        "data_type":"COLUMN_TYPE",
        "values":"SEND_DATA",
        "records":"SEND_RECORD",
        "check_batch_id":"ID"
    },
    "opermap":{
        "fullload":"R",
        "insert":"I",
        "update":"U",
        "delete":"D",
        "ddl":"DDL"
    },
    "loaderTime":1,
    "rid":1,
    "useupdatemark":1,
    "sendtype":1,
    "ddl":0,
    "updatetodeleteandinsert":0,
    "ColNameCase":0,
    "columnType":1,
    "primaryKey":1,
    "batchId":1,
    "sendbatch":0,
    "real_check":1,
    "full_check":1,
    "skipddl":1,
    "chk_real_topic":"SAPSR3_INC_CHECK:0",
    "chk_full_topic":"SAPSR3_CHECK:0",
    "chk_topic":"chk_topic_01",
    "includeDataType":"1",
    "jsontype":"json_module"
}