如何检查debezium快照是否完成

Question

我需要在表中添加更多表。Debezium Postgres连接器中的白名单。我发现了这里提到的一种方法。它表明：

快照完成后，使用更新的白名单启动原始连接器

但是如何才能发现快照是否完整呢？

Answer 1

有多种方法可以做到这一点。您可以检查Kafka Connect日志，或者在收到的最新事件中读取payload.source.snapshot的布尔值，或者使用JMX，其中每个连接器的MBean都有SnapshotFendedboolean属性。

Answer 2

跟踪连接。补偿。存储连接群集使用的主题，并记下服务器。连接器中指定的id。

对于完整的初始快照，您应该在快照完成后看到以下条目。

{ 
    "file":"my-database-bin.000004",
    "pos":143
}

当它处理事件并跟踪最新的数据库日志时，它将根据服务器id更新偏移的状态。

{
    "ts_sec": 1610704790,
    "file": "my-database-bin.000004",
    "row": 2,
    "pos": 134,
    "server_id": 2001186
    ...
}

它现在正在跟踪主binlog并提交偏移量，这一事实是对快照已完成的确认，因为只有快照完成后，连接器才会根据源偏移量进行监视。