ticdc同步到下游kafka任务报错

[tao7]

为提高效率，提问时请提供以下信息，问题描述清晰可优先响应。

• 【TiDB 版本】：v4.0.6
• 【问题描述】：ticdc同步到下游kafka任务报错，具体情况如下：
  1、[tidb@node1 ~]$ tiup cdc cli changefeed list --pd=http://10.22.45.111:2379
  Starting component cdc: /home/tidb/.tiup/components/cdc/v4.0.6/cdc cli changefeed list --pd=http://10.22.45.111:2379
  [
  {
  “id”: “cdc-hollycas-record”,
  “summary”: {
  “state”: “normal”,
  “tso”: 419760234616061954,
  “checkpoint”: “2020-09-28 09:56:59.208”,
  “error”: {
  “addr”: “10.22.45.111:8300”,
  “code”: “CDC-owner-1001”,
  “message”: “[CDC:ErrMetaListDatabases][tikv:9001]PD server timeout”
  }
  }
  }
  ]
  2、[tidb@node1 ~]$ tiup cdc cli changefeed pause --pd=http://10.22.45.111:2379 --changefeed-id cdc-hollycas-record
  3、[tidb@node1 ~]$ tiup cdc cli changefeed resume --pd=http://10.22.45.111:2379 --changefeed-id cdc-hollycas-record
  Starting component cdc: /home/tidb/.tiup/components/cdc/v4.0.6/cdc cli changefeed resume --pd=http://10.22.45.111:2379 --changefeed-id cdc-hollycas-record
  4、[tidb@node1 ~]$ tiup cdc cli changefeed list --pd=http://10.22.45.111:2379
  Starting component cdc: /home/tidb/.tiup/components/cdc/v4.0.6/cdc cli changefeed list --pd=http://10.22.45.111:2379
  [
  {
  “id”: “cdc-hollycas-record”,
  “summary”: {
  “state”: “stopped”,
  “tso”: 419760253857431556,
  “checkpoint”: “2020-09-28 09:58:12.608”,
  “error”: {
  “addr”: “10.22.45.111:8300”,
  “code”: “CDC:ErrProcessorUnknown”,
  “message”: “[CDC:ErrKafkaFlushUnfished]flush not finished before producer close”
  }
  }
  }
  ]

若提问为性能优化、故障排查类问题，请下载脚本运行。终端输出的打印结果，请务必全选并复制粘贴上传。

[tao7]

tiup cdc cli changefeed resume --pd=http://10.22.45.111:2379 --changefeed-id cdc-hollycas-record 后解决，结贴。

[来了老弟]