8.7. 监控 Debezium PostgreSQL 连接器性能
Debezium PostgreSQL 连接器提供了两种类型的指标，除了对 Zookeeper、Kafka 和 Kafka Connect 提供的 JMX 指标的内置支持之外。
Debezium 监控文档 提供了如何使用 JMX 公开这些指标的详细信息。
8.7.1. 在 PostgreSQL 数据库快照过程中监控 Debezium
MBean 是 debezium.postgres:type=connector-metrics,context=snapshot,server= <topic.prefix>。
快照指标不会公开，除非快照操作处于活跃状态，或者快照自上次连接器启动以来发生。
下表列出了可用的 shapshot 指标。
| 属性 | 类型 | 描述 |
|---|---|---|
|
| 连接器已读取的最后一个快照事件。 | |
|
| 连接器已读取并处理最新事件以来的毫秒数。 | |
|
| 此连接器自上次启动或重置后看到的事件总数。 | |
|
| 通过连接器上配置的 include/exclude 列表过滤规则过滤的事件数量。 | |
|
| 连接器捕获的表列表。 | |
|
| 在快照和主 Kafka Connect 循环之间传递事件的长度。 | |
|
| 队列的空闲容量，用于在快照和主 Kafka Connect 循环之间传递事件。 | |
|
| 包括在快照中的表的总数。 | |
|
| 快照必须复制的表数。 | |
|
| 快照是否已启动。 | |
|
| 快照是否已暂停。 | |
|
| 快照是否中止。 | |
|
| 快照是否完成。 | |
|
| 快照为止所花费的秒数，即使未完成也是如此。也包括快照暂停的时间。 | |
|
| 快照暂停的秒数。如果快照暂停几次，暂停的时间会添加。 | |
|
| 包含快照中每个表的行数的映射。表会在处理过程中逐步添加到映射中。更新每个 10,000 行扫描并在完成表后。 | |
|
|
队列的最大缓冲区（以字节为单位）。如果将 | |
|
| 队列中记录的当前卷（以字节为单位）。 |
连接器还在执行增量快照时提供以下额外快照指标：
| 属性 | 类型 | 描述 |
|---|---|---|
|
| 当前快照块的标识符。 | |
|
| 定义当前块的主密钥集的下限。 | |
|
| 定义当前块的主密钥集的上限。 | |
|
| 当前快照表的主密钥集的下限。 | |
|
| 当前快照表的主密钥集的上限。 |
8.7.2. 监控 Debezium PostgreSQL 连接器记录流
MBean 是 debezium.postgres:type=connector-metrics,context=streaming,server= <topic.prefix>。
下表列出了可用的流指标。
| 属性 | 类型 | 描述 |
|---|---|---|
|
| 连接器已读取的最后一个流事件。 | |
|
| 连接器已读取并处理最新事件以来的毫秒数。 | |
|
| 此连接器自上一次启动或指标重置以来看到的事件总数。 | |
|
| 此连接器自上次启动或指标重置以来看到的创建事件总数。 | |
|
| 此连接器自上次启动或指标重置以来看到的更新事件总数。 | |
|
| 此连接器自上次启动或指标重置以来看到的删除事件总数。 | |
|
| 通过连接器上配置的 include/exclude 列表过滤规则过滤的事件数量。 | |
|
| 连接器捕获的表列表。 | |
|
| 在流器和主 Kafka Connect 循环之间传递事件的长度。 | |
|
| 在流器和主 Kafka Connect 循环之间传递事件的队列的可用容量。 | |
|
| 表示连接器目前是否连接到数据库服务器的标记。 | |
|
| 最后一次更改事件时间戳和连接器处理它之间的毫秒数。这些值将讨论运行数据库服务器和连接器的计算机上时钟之间的任何区别。 | |
|
| 已提交的已处理事务的数量。 | |
|
| 最后收到的事件的协调。 | |
|
| 最后处理事务的事务的事务标识符。 | |
|
|
队列的最大缓冲区（以字节为单位）。如果将 | |
|
| 队列中记录的当前卷（以字节为单位）。 |
