关于 cannal kafka 接收到的json 缺少 before

版本: canal v1.1.1 我在 client 模式下 我可以获取一条数据更新前的json 和 更新后的json，当我引入 cannal kafka 传输过来的json 字符串无法看到更新前json 相关内容，我这是属于正常的吗。

返回的json 如下

{ "data": [ { "ID": "8419", "CAR_CODE": "FZJN00008419", "CREATED_BY": "2", "CREATED_DATE": "2019-04-23 10:44:43", "UPDATED_BY": "23470", "UPDATED_DATE": "2019-08-27 08:53:43", "IS_DELETED": "0", "COMPANY_ID": "136", "CAR_SERVICE_BELONG": "136", "CAR_NO": "沪C222565", "CAR_TYPE_ID": "8", "PARKING_ID": null, "BUY_DATE": "2019-04-23", "CAR_FRAME": "123321", "ENGINE_NO": null, "CAR_CERTIFICATE": null, "OIL_CARD_NO": "", "LICENSE_PLATE_TYPE": "黄", "CAR_STATUS": "1", "GPS_DEVICE_NO": "", "CAR_ADDRESS": null, "CAR_LNG_LAT": null, "GPS_MILEAGE": "0.0", "CAR_SPEED": "0.0", "CAR_DIRECTION": null, "CAR_DIRECTION_LAST_TIME": null, "CAR_TO_END_DISTANCE": null, "ACC_STATUS": null, "CAR_PHOTO": null, "CAR_OPERATE_PHOTO": null, "DRIVING_PHOTO": null, "OIL_CARD_MONEY": "1.0", "year_check_id": null, "jq_Insurance_id": null, "sy_Insurance_id": null, "qd_Insurance_id": null, "send_repair_date": null, "dispatch_config_id": null, "is_dispatch": "0", "car_brand": "解放牌", "completion_time": null, "single_pressure": "0", "number_tasks_today": "0", "current_technician_id": "31798", "current_task_status": null, "current_task_type": null, "busy_flag": null, "work_status": null, "car_tax_photo": null, "car_contract_photo": null, "car_buy_mon": null, "purchase_tax": null, "CAR_RUN_DIRECTION": null, "pressure_config": null, "is_lease": "0", "lease_type": null, "lease_object": "", "gps_type": null, "is_platform_visible": null, "platform_company_ids": null, "specification": "专用车大" } ], "database": "ssr_test_20190420", "es": 1566867223000, "id": 458054, "isDdl": false, "mysqlType": { "ID": "int(11)", "CAR_CODE": "varchar(255)", "CREATED_BY": "varchar(10)", "CREATED_DATE": "datetime", "UPDATED_BY": "varchar(10)", "UPDATED_DATE": "datetime", "IS_DELETED": "tinyint(1)", "COMPANY_ID": "int(11)", "CAR_SERVICE_BELONG": "int(11)", "CAR_NO": "varchar(15)", "CAR_TYPE_ID": "int(11)", "PARKING_ID": "int(11)", "BUY_DATE": "date", "CAR_FRAME": "varchar(50)", "ENGINE_NO": "varchar(50)", "CAR_CERTIFICATE": "varchar(50)", "OIL_CARD_NO": "varchar(100)", "LICENSE_PLATE_TYPE": "varchar(15)", "CAR_STATUS": "int(11)", "GPS_DEVICE_NO": "varchar(30)", "CAR_ADDRESS": "varchar(100)", "CAR_LNG_LAT": "varchar(50)", "GPS_MILEAGE": "decimal(8,2)", "CAR_SPEED": "decimal(8,2)", "CAR_DIRECTION": "varchar(10)", "CAR_DIRECTION_LAST_TIME": "int(11)", "CAR_TO_END_DISTANCE": "int(11)", "ACC_STATUS": "varchar(10)", "CAR_PHOTO": "bigint(25)", "CAR_OPERATE_PHOTO": "bigint(25)", "DRIVING_PHOTO": "bigint(25)", "OIL_CARD_MONEY": "decimal(8,2)", "year_check_id": "int(11)", "jq_Insurance_id": "int(11)", "sy_Insurance_id": "int(11)", "qd_Insurance_id": "int(11)", "send_repair_date": "datetime", "dispatch_config_id": "int(11)", "is_dispatch": "int(11)", "car_brand": "varchar(255)", "completion_time": "datetime", "single_pressure": "int(11)", "number_tasks_today": "int(11)", "current_technician_id": "int(11)", "current_task_status": "tinyint(4)", "current_task_type": "varchar(32)", "busy_flag": "int(11)", "work_status": "int(11)", "car_tax_photo": "bigint(25)", "car_contract_photo": "bigint(25)", "car_buy_mon": "decimal(10,0)", "purchase_tax": "decimal(5,0)", "CAR_RUN_DIRECTION": "char(1)", "pressure_config": "int(11)", "is_lease": "int(11)", "lease_type": "int(11)", "lease_object": "varchar(32)", "gps_type": "int(11)", "is_platform_visible": "int(11)", "platform_company_ids": "varchar(64)", "specification": "varchar(255)" }, "old": [ { "UPDATED_BY": "31798", "UPDATED_DATE": "2019-08-23 09:30:15", "CAR_NO": "沪C22222", "OIL_CARD_MONEY": "0.0" } ], "pkNames": null, "sql": "", "sqlType": { "ID": 4, "CAR_CODE": 12, "CREATED_BY": 12, "CREATED_DATE": 93, "UPDATED_BY": 12, "UPDATED_DATE": 93, "IS_DELETED": -7, "COMPANY_ID": 4, "CAR_SERVICE_BELONG": 4, "CAR_NO": 12, "CAR_TYPE_ID": 4, "PARKING_ID": 4, "BUY_DATE": 91, "CAR_FRAME": 12, "ENGINE_NO": 12, "CAR_CERTIFICATE": 12, "OIL_CARD_NO": 12, "LICENSE_PLATE_TYPE": 12, "CAR_STATUS": 4, "GPS_DEVICE_NO": 12, "CAR_ADDRESS": 12, "CAR_LNG_LAT": 12, "GPS_MILEAGE": 3, "CAR_SPEED": 3, "CAR_DIRECTION": 12, "CAR_DIRECTION_LAST_TIME": 4, "CAR_TO_END_DISTANCE": 4, "ACC_STATUS": 12, "CAR_PHOTO": -5, "CAR_OPERATE_PHOTO": -5, "DRIVING_PHOTO": -5, "OIL_CARD_MONEY": 3, "year_check_id": 4, "jq_Insurance_id": 4, "sy_Insurance_id": 4, "qd_Insurance_id": 4, "send_repair_date": 93, "dispatch_config_id": 4, "is_dispatch": 4, "car_brand": 12, "completion_time": 93, "single_pressure": 4, "number_tasks_today": 4, "current_technician_id": 4, "current_task_status": -6, "current_task_type": 12, "busy_flag": 4, "work_status": 4, "car_tax_photo": -5, "car_contract_photo": -5, "car_buy_mon": 3, "purchase_tax": 3, "CAR_RUN_DIRECTION": 1, "pressure_config": 4, "is_lease": 4, "lease_type": 4, "lease_object": 12, "gps_type": 4, "is_platform_visible": 4, "platform_company_ids": 12, "specification": 12 }, "table": "vr_car_info", "ts": 1566867223150, "type": "UPDATE" }

我确定我的 binlog 是 row

原提问者GitHub用户Suaron-Biliu