如何重启Debezium连接器对RDS Postgres单表的全量加载？

不需要重新全量加载所有10张表，Debezium提供了多种方式实现单表的全量快照触发，以下是两种常用方法：

方法一：使用Debezium信号（Signal）机制（推荐） #

这是Debezium官方推荐的方式，无需修改原有连接器配置，也不会中断其他表的同步：

• 首先确认你的连接器配置中已开启信号功能：检查是否包含signal.enabled=true。如果未配置，先通过Kafka Connect API更新连接器配置添加该参数，之后重启连接器（此重启不会触发全量快照）。
• 向Debezium的信号主题发送触发快照的消息：
  默认信号主题为debezium-signals，如果你的连接器配置了signal.kafka.topic参数，则使用配置的主题名称。发送的JSON消息格式如下：

  {
    "type": "execute-snapshot",
    "data": {
      "connectorName": "your-connector-name",
      "collection": "public.target-table",
      "type": "incremental"
    }
  }
  

  其中：
  • connectorName替换为你的Debezium连接器名称
  • collection替换为目标表的完整标识（PostgreSQL通常为schema.表名，默认schema是public）
  • type设为incremental表示先执行全量快照，之后继续捕获该表的增量变更，不会影响其他表的正常同步

方法二：临时修改连接器配置触发快照（不推荐，仅作备选） #

如果无法使用信号机制，可以通过临时调整配置的方式实现，但操作相对繁琐：

• 暂停目标连接器：

  curl -X PUT http://<kafka-connect-host>:8083/connectors/<your-connector-name>/pause
  

• 更新连接器配置，将table.include.list修改为仅包含目标表：

  curl -X PUT http://<kafka-connect-host>:8083/connectors/<your-connector-name>/config \
  -H "Content-Type: application/json" \
  -d '{
    "table.include.list": "public.target-table",
    // 保留其他原有配置参数
  }'
  

• 重置连接器的偏移量：

  curl -X DELETE http://<kafka-connect-host>:8083/connectors/<your-connector-name>/offsets
  

• 重启连接器触发全量快照：

  curl -X POST http://<kafka-connect-host>:8083/connectors/<your-connector-name>/restart
  

• 待目标表快照完成后，再次暂停连接器，将table.include.list恢复为原来的10张表配置，最后重启连接器恢复正常同步

内容的提问来源于stack exchange，提问作者Christian