场景：
使用cdc同步数据至kafka
执行命令：
tiup cdc cli changefeed create --pd=http://10.x.x.x:2379 --sink-uri=“kafka://10.x.x.x:19092/ty_cdc_canal?kafka-version=2.1.1&partition-num=3&max-message-bytes=67108864&replication-factor=1&protocol=canal&kafka-client-id=ty_cdc_canal” --changefeed-id=“simple-replication-task” --sort-engine=“unified”
遇到问题：
查看日志，发现error: CDC:ErrDecodeFailed]decode failed: failed to unmarshal task status: %s%!(EXTRA *errors.withMessage=Unmarshal data
附：
执行命令后输出：
{“sink-uri”:“kafka://10.x.x.x:19092/ty_cdc_canal?kafka-version=2.1.1\u0026partition-num=3\u0026max-message-bytes=67108864\u0026replication-factor=1\u0026protocol=canal\u0026kafka-client-id=ty_cdc_canal”,“opts”:{“max-message-bytes”:“67108864”},“create-time”:“2021-06-10T17:27:45.750698608+08:00”,“start-ts”:425542899687489537,“target-ts”:0,“admin-job-type”:0,“sort-engine”:“unified”,“config”:{“case-sensitive”:true,“enable-old-value”:true,“force-replicate”:false,“check-gc-safe-point”:true,“filter”:{“rules”:[“.”],“ignore-txn-start-ts”:null},“mounter”:{“worker-num”:16},“sink”:{“dispatchers”:null,“protocol”:“canal”},“cyclic-replication”:{“enable”:false,“replica-id”:0,“filter-replica-ids”:null,“id-buckets”:0,“sync-ddl”:false},“scheduler”:{“type”:“table-number”,“polling-time”:-1}},“state”:“normal”,“history”:null,“error”:null,“sync-point-enabled”:false,“sync-point-interval”:600000000000,“creator-version”:“v5.0.2”}
查询命令输出：
