Debezium日常分享系列之:Debezium2.5稳定版本之Monitoring

Debezium日常分享系列之:Debezium2.5稳定版本之Monitoring

Debezium系列之:安装jmx导出器监控debezium指标

除了 Zookeeper、Kafka 和 Kafka Connect 提供的对 JMX 指标的内置支持之外,Debezium MySQL 连接器还提供三种类型的指标。

  • 快照指标提供有关执行快照时连接器操作的信息。
  • 当连接器读取二进制日志时,流指标提供有关连接器操作的信息。
  • 架构历史记录指标提供有关连接器架构历史记录状态的信息。

一、Snapshot metrics

MBean 为 debezium.mysql:type=connector-metrics,context=snapshot,server=<topic.prefix>。

除非快照操作处于活动状态,或者自上次连接器启动以来已发生快照,否则不会公开快照指标。

下表列出了可用的快照指标。

属性 类型 描述
LastEvent string 连接器读取的最后一个快照事件。
MilliSecondsSinceLastEvent long 自连接器读取并处理最近事件以来的毫秒数。
TotalNumberOfEventsSeen long 自上次启动或重置以来此连接器发生的事件总数。
NumberOfEventsFiltered long 已按连接器上配置的包含/排除列表过滤规则过滤的事件数。
CapturedTables string[] 连接器捕获的表的列表。
QueueTotalCapacity int 用于在快照器和主 Kafka Connect 循环之间传递事件的队列长度。
QueueRemainingCapacity int 用于在快照器和主 Kafka Connect 循环之间传递事件的队列的可用容量。
TotalTableCount int 快照中包含的表总数。
RemainingTableCount int 快照尚未复制的表的数量。
SnapshotRunning boolean 快照是否已启动。
SnapshotPaused boolean 快照是否暂停。
SnapshotAborted boolean 快照是否被中止。
SnapshotCompleted boolean 快照是否完成。
SnapshotDurationInSeconds long 到目前为止快照所用的总秒数(即使尚未完成)。还包括快照暂停的时间。
SnapshotPausedDurationInSeconds long 快照暂停的总秒数。如果快照暂停多次,则暂停时间会累加。
RowsScanned Map<String, Long> 包含快照中每个表扫描的行数的映射。表在处理过程中逐渐添加到映射中。每扫描 10,000 行并完成表格后更新一次。
MaxQueueSizeInBytes long 队列的最大缓冲区(以字节为单位)。如果 max.queue.size.in.bytes 设置为正 long 值,则此指标可用。
CurrentQueueSizeInBytes long 队列中的当前记录量(以字节为单位)。

执行增量快照时,连接器还提供以下附加快照指标:

属性 类型 描述
ChunkId string 当前快照块的标识符。
ChunkFrom string 定义当前块的主键集的下界。
ChunkTo string 定义当前块的主键集的上限。
TableFrom string 当前快照表的主键集的下界。
TableTo string 当前快照表的主键集的上限。

Debezium MySQL 连接器还提供 HoldingGlobalLock 自定义快照指标。该指标设置为一个布尔值,指示连接器当前是否持有全局或表写入锁定。

二、Streaming metrics

仅当启用 binlog 事件缓冲时,事务相关属性才可用。有关更多详细信息,请参阅高级连接器配置属性中的 binlog.buffer.size。 :水平偏移:+1

MBean 为 debezium.mysql:type=connector-metrics,context=streaming,server=<topic.prefix>。

下表列出了可用的流指标。

属性 类型 描述
LastEvent string 连接器读取的最后一个流事件。
MilliSecondsSinceLastEvent long 自连接器读取并处理最近事件以来的毫秒数。
TotalNumberOfEventsSeen long 自上次启动或指标重置以来,该连接器已经看到的事件总数。
TotalNumberOfCreateEventsSeen long 自上次启动或指标重置以来此连接器已看到的创建事件总数。
TotalNumberOfUpdateEventsSeen long 自上次启动或指标重置以来此连接器看到的更新事件总数。
TotalNumberOfDeleteEventsSeen long 自上次启动或指标重置以来此连接器看到的删除事件总数。
NumberOfEventsFiltered long 已按连接器上配置的包含/排除列表过滤规则过滤的事件数。
CapturedTables string[] 连接器捕获的表的列表。
QueueTotalCapacity int 用于在流送器和主 Kafka Connect 循环之间传递事件的队列长度。
QueueRemainingCapacity int 用于在流处理器和主 Kafka Connect 循环之间传递事件的队列的可用容量。
Connected boolean 指示连接器当前是否连接到数据库服务器的标志。
MilliSecondsBehindSource long 最后更改事件的时间戳与连接器处理该事件之间的毫秒数。这些值将包含运行数据库服务器和连接器的计算机上时钟之间的任何差异。
NumberOfCommittedTransactions long 已提交的已处理事务数。
SourceEventPosition Map<String, String> 最后接收到的事件的坐标。
LastTransactionId string 最后处理交易的交易标识符。
MaxQueueSizeInBytes long 队列的最大缓冲区(以字节为单位)。如果 max.queue.size.in.bytes 设置为正 long 值,则此指标可用。
CurrentQueueSizeInBytes long 队列中的当前记录量(以字节为单位)。

Debezium MySQL 连接器还提供以下附加流指标:

表 28. 其他流媒体指标的描述

属性 类型 描述
BinlogFilename string 连接器最近读取的二进制日志文件的名称。
BinlogPosition long 连接器读取的二进制日志中的最新位置(以字节为单位)。
IsGtidModeEnabled boolean 指示连接器当前是否正在跟踪来自 MySQL 服务器的 GTID 的标志。
GtidSet string 连接器在读取 binlog 时处理的最新 GTID 集的字符串表示形式。
NumberOfSkippedEvents long MySQL 连接器已跳过的事件数。通常,由于 MySQL binlog 中的事件格式错误或无法解析,事件会被跳过。
NumberOfDisconnects long MySQL 连接器断开连接的次数。
NumberOfRolledBackTransactions long 已回滚且未流式传输的已处理事务的数量。
NumberOfNotWellFormedTransactions long 不符合 BEGIN + COMMIT/ROLLBACK 预期协议的事务数量。正常情况下该值应为 0。
NumberOfLargeTransactions long 未装入前瞻缓冲区的事务数。为了获得最佳性能,该值应明显小于 NumberOfCommitedTransactions 和 NumberOfRolledBackTransactions。

三、Schema history metrics

MBean 为 debezium.mysql:type=connector-metrics,context=schema-history,server=<topic.prefix>。

下表列出了可用的架构历史记录指标。

属性 类型 描述
Status string STOPPED、RECOVERING(从存储中恢复历史记录)、RUNNING 之一描述数据库模式历史记录的状态。
RecoveryStartTime long 恢复开始的时间(以纪元秒为单位)。
ChangesRecovered long 在恢复阶段读取的更改数。
ChangesApplied long 恢复和运行时应用的架构更改总数。
MilliSecondsSinceLast​RecoveredChange long 从历史存储中恢复上次更改以来经过的毫秒数。
MilliSecondsSinceLast​AppliedChange long 自上次应用更改以来经过的毫秒数。
LastRecoveredChange string 从历史存储中恢复的最后更改的字符串表示形式。
LastAppliedChange string 最后应用的更改的字符串表示形式。

最近更新

  1. TCP协议是安全的吗?

    2024-03-24 08:20:02       16 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2024-03-24 08:20:02       16 阅读
  3. 【Python教程】压缩PDF文件大小

    2024-03-24 08:20:02       15 阅读
  4. 通过文章id递归查询所有评论(xml)

    2024-03-24 08:20:02       18 阅读

热门阅读

  1. 【测试思考】设计测试用例时,你在想什么

    2024-03-24 08:20:02       18 阅读
  2. Electron IPC通信机制深度解析与实例演示

    2024-03-24 08:20:02       17 阅读
  3. 如何系统地自学 Python?

    2024-03-24 08:20:02       14 阅读
  4. 学习资料记录

    2024-03-24 08:20:02       16 阅读
  5. 20 有效的括号

    2024-03-24 08:20:02       17 阅读
  6. 机器翻译评价指标 BLEU分数

    2024-03-24 08:20:02       21 阅读
  7. Day31 贪心算法

    2024-03-24 08:20:02       17 阅读
  8. Ubuntu 22.04 安装配置时间同步服务器

    2024-03-24 08:20:02       19 阅读
  9. Eureka和Nacos的关系

    2024-03-24 08:20:02       17 阅读
  10. Python学习笔记06

    2024-03-24 08:20:02       16 阅读
  11. B3626 跳跃机器人

    2024-03-24 08:20:02       21 阅读
  12. 第二十七章:Docker Nginx 部署

    2024-03-24 08:20:02       15 阅读
  13. P9240 [蓝桥杯 2023 省 B] 冶炼金属 Python

    2024-03-24 08:20:02       15 阅读