Debezium SQL 服务器连接器 Kafka 初始快照

Debezium SQL Server Connector Kafka Initial Snapshot

根据 Debezium SQL 服务器连接器文档,初始快照仅首先在连接器上触发 运行。 但是,如果我删除连接器并创建新的但具有相同名称的连接器,则初始快照也无法正常工作。 这是设计使然还是已知问题? 任何帮助表示赞赏

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

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

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