Debezium SQL Server 连接器 Kafka 初始快照

Posted 2023-03-23

【中文标题】Debezium SQL Server 连接器 Kafka 初始快照

【英文标题】：Debezium SQL Server Connector Kafka Initial Snapshot

【发布时间】：2020-08-22 11:07:33

【问题描述】：

根据 Debezium SQL Server 连接器文档，初始快照仅在连接器首次运行时触发。 但是，如果我删除连接器并创建新的但具有相同名称的连接器，初始快照也不起作用。 这是设计使然还是已知问题？ 任何帮助表示赞赏

【参考方案1】：

给您的连接器一个新的 database.server.name 值或创建一个新主题。快照没有再次触发的原因是您的主题和消费者的当前偏移值已经通过了快照计数索引。

【参考方案2】：

Kafka Connect 存储有关连接器的详细信息，例如它们的快照状态和摄取进度，即使它们已被删除。如果您使用相同的名称重新创建它，它将假定它是相同的连接器，因此将尝试从前一个连接器到达的位置继续。

如果您希望连接器从头开始（即运行快照等），那么您需要给连接器一个新名称。 （从技术上讲，您也可以进入 Kafka Connect 并处理内部数据以删除同名连接器的数据，但这可能是个坏主意）