如何通过Debezium无CDC事件/记录推送SQL表Schema至Apicurio注册表

针对你提出的「无CDC记录、无需修改表记录，将SQL数据库中所有启用CDC的表Schema推送至Apicurio注册表」的需求，有两种可靠方案：

1. 配置Debezium执行仅Schema快照 #

Debezium内置的快照机制可在连接器启动时主动抓取表结构，完全不依赖数据变更事件：

• 在连接器配置中设置snapshot.mode=schema_only，该模式仅读取启用CDC的表的Schema信息，不会同步任何表数据，启动后直接将Schema推送至Apicurio。
• 示例配置片段：

{
  "name": "your-sql-connector",
  "config": {
    "connector.class": "io.debezium.connector.sqlserver.SqlServerConnector",
    "database.hostname": "your-db-host",
    "database.port": "1433",
    "database.user": "db-user",
    "database.password": "db-pass",
    "database.dbname": "your-db",
    "database.server.name": "db-server",
    "schema.registry.url": "http://apicurio-host:8080/apis/registry/v2",
    "value.converter": "io.apicurio.registry.utils.converter.AvroConverter",
    "value.converter.apicurio.registry.url": "http://apicurio-host:8080/apis/registry/v2",
    "snapshot.mode": "schema_only"
  }
}

• 注意：需确保数据库账号拥有读取表元数据的权限，同时连接器已正确配置与Apicurio的连接参数。

2. 手动触发已运行连接器的Schema快照 #

如果连接器已经在运行，无需重启即可触发Schema同步：

• 通过Debezium的REST API发送快照触发请求，指定仅同步Schema：

POST /connectors/{connector-name}/snapshot

• 请求体可附加snapshot.mode=schema_only参数，限制仅抓取Schema，避免同步数据。

提前致谢

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