6.7. 监控 Debezium Oracle 连接器性能


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

有关如何通过 JMX 公开这些指标的详细信息,请参阅监控 文档

6.7.1. Debezium Oracle 连接器快照指标

MBeandebezium.oracle:type=connector-metrics,context=snapshot,server= <oracle.server.name>

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

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

Expand
属性类型描述

LastEvent

字符串

连接器读取的最后一个快照事件。

MilliSecondsSinceLastEvent

long

连接器读取和处理最新事件以来的毫秒数。

TotalNumberOfEventsSeen

long

此连接器从上次启动或重置后看到的事件总数。

NumberOfEventsFiltered

long

由连接器中配置的 include/exclude 列表过滤规则过滤的事件数。

CapturedTables

string[]

连接器捕获的表列表。

QueueTotalCapacity

int

用于在快照和主 Kafka Connect 循环之间传递事件的队列长度。

QueueRemainingCapacity

int

用于在快照和主 Kafka Connect 循环之间传递事件的队列的空闲容量。

TotalTableCount

int

包括在快照中的表的总数。

RemainingTableCount

int

快照要复制的表数。

SnapshotRunning

布尔值

快照是否启动。

SnapshotPaused

布尔值

快照是否暂停。

SnapshotAborted

布尔值

快照是否中止。

SnapshotCompleted

布尔值

快照是否完成。

SnapshotDurationInSeconds

long

快照目前花费的秒数,即使未完成也是如此。还包括快照暂停时的时间。

SnapshotPausedDurationInSeconds

long

快照暂停的秒数。如果快照暂停多次,则暂停的时间会增加。

RowsScanned

Map<String, Long>

包含快照中每个表扫描的行数的映射。表在处理期间逐步添加到映射中。更新每个 10,000 行扫描,并在完成表后更新。

MaxQueueSizeInBytes

long

队列的最大缓冲区(以字节为单位)。如果 max.queue.size.in.bytes 设置为正长值,则此指标可用。

CurrentQueueSizeInBytes

long

队列中记录的当前卷(以字节为单位)。

在执行增量快照时,连接器还提供以下额外快照指标:

Expand
属性类型描述

ChunkId

字符串

当前快照块的标识符。

ChunkFrom

字符串

定义当前块的主键集的下限。

ChunkTo

字符串

定义当前块的主密钥集的上限。

TableFrom

字符串

当前快照表的主键集的下限。

TableTo

字符串

当前快照表的主键集的上限。

6.7.2. Debezium Oracle 连接器流指标

MBeandebezium.oracle:type=connector-metrics,context=streaming,server= <oracle.server.name>

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

Expand
属性类型描述

LastEvent

字符串

连接器读取的最后一个流事件。

MilliSecondsSinceLastEvent

long

连接器读取和处理最新事件以来的毫秒数。

TotalNumberOfEventsSeen

long

此连接器自上次开始或指标重置以来看到的事件总数。

TotalNumberOfCreateEventsSeen

long

此连接器自上次开始或指标重置以来看到的创建事件总数。

TotalNumberOfUpdateEventsSeen

long

此连接器自上次开始或指标重置以来看到的更新事件总数。

TotalNumberOfDeleteEventsSeen

long

此连接器自上次开始或指标重置以来看到的删除事件总数。

NumberOfEventsFiltered

long

由连接器中配置的 include/exclude 列表过滤规则过滤的事件数。

CapturedTables

string[]

连接器捕获的表列表。

QueueTotalCapacity

int

用于在流和主 Kafka Connect 循环之间传递事件的队列长度。

QueueRemainingCapacity

int

用于在流和主 Kafka Connect 循环之间传递事件的队列的空闲容量。

Connected

布尔值

表示连接器当前是否连接到数据库服务器的标记。

MilliSecondsBehindSource

long

最后一次更改事件时间戳和连接器处理之间毫秒的数量。该值将限制运行数据库服务器和连接器的机器上时钟之间的差别。

NumberOfCommittedTransactions

long

已提交的已处理的事务数量。

SourceEventPosition

Map<String, String>

最后一次接收的事件的协调。

LastTransactionId

字符串

最后一次处理的事务的事务标识符。

MaxQueueSizeInBytes

long

队列的最大缓冲区(以字节为单位)。如果 max.queue.size.in.bytes 设置为正长值,则此指标可用。

CurrentQueueSizeInBytes

long

队列中记录的当前卷(以字节为单位)。

Debezium Oracle 连接器还提供以下额外的流指标:

Expand
表 6.16. 其他流指标的描述
属性类型描述

CurrentScn

字符串

已处理的最新系统更改号。

OldestScn

字符串

事务缓冲区中最旧的系统更改数。

CommittedScn

字符串

最后提交的系统会更改事务缓冲区中的数字。

OffsetScn

字符串

系统更改号当前写入连接器的偏移量。

CurrentRedoLogFileName

string[]

当前被设置的日志文件的数组。

MinimumMinedLogCount

long

为任何 LogMiner 会话指定的最小日志数。

MaximumMinedLogCount

long

为任何 LogMiner 会话指定的最大日志数。

RedoLogStatus

string[]

每个最小日志文件的当前状态数组,格式为 filename|status

SwitchCounter

int

数据库在最后一天执行日志交换机的次数。

LastCapturedDmlCount

long

最后一次 LogMiner 会话查询中观察到的 DML 操作数量。

MaxCapturedDmlInBatch

long

处理单个 LogMiner 会话查询时观察到的最大 DML 操作数。

TotalCapturedDmlCount

long

观察到 DML 操作总数。

FetchingQueryCount

long

执行的 LogMiner 会话查询(也称为批处理)的总数。

LastDurationOfFetchQueryInMilliseconds

long

最后一次 LogMiner 会话查询的持续时间,以毫秒为单位获取。

MaxDurationOfFetchQueryInMilliseconds

long

任何 LogMiner 会话查询的最长持续时间(以毫秒为单位)。

LastBatchProcessingTimeInMilliseconds

long

处理最后的 LogMiner 查询批处理持续时间会导致毫秒。

TotalParseTimeInMilliseconds

long

解析 DML 事件 SQL 语句的时间(毫秒)。

LastMiningSessionStartTimeInMilliseconds

long

启动最后一次 LogMiner 会话的时间(毫秒)。

MaxMiningSessionStartTimeInMilliseconds

long

启动 LogMiner 会话的最长时间(毫秒)。

TotalMiningSessionStartTimeInMilliseconds

long

连接器启动 LogMiner 会话所消耗的总持续时间(毫秒)。

MinBatchProcessingTimeInMilliseconds

long

来自单个 LogMiner 会话的处理结果的最短持续时间(毫秒)。

MaxBatchProcessingTimeInMilliseconds

long

来自单个 LogMiner 会话的处理结果的最大持续时间(毫秒)。

TotalProcessingTimeInMilliseconds

long

来自 LogMiner 会话的处理结果的总持续时间(毫秒)。

TotalResultSetNextTimeInMilliseconds

long

JDBC 驱动程序从日志最小视图获取下一个行所花费的总持续时间(毫秒)。

TotalProcessedRows

long

在所有会话中的日志最小视图中处理的行总数。

BatchSize

int

日志减去每个数据库往返查询所获取的条目数。

MillisecondToSleep betweenMiningQuery

long

从日志 mining 视图获取另一批处理结果前,连接器睡眠的毫秒。

MaxBatchProcessingThroughput

long

从日志减视图处理的最大行/秒数。

AverageBatchProcessingThroughput

long

从日志减上处理的平均行/秒数。

LastBatchProcessingThroughput

long

从最后一个批处理的日志最小视图中处理的平均行/秒数。

NetworkConnectionProblemsCounter

long

检测到的连接问题数量。

HoursToKeepTransactionInBuffer

int

连接器的内存中缓冲区保留的小时数,而不在丢弃前提交或回滚。如需了解更多详细信息,请参阅 log.mining.transaction.retention

NumberOfActiveTransactions

long

事务缓冲区中当前活动事务的数量。

NumberOfCommittedTransactions

long

事务缓冲区中的提交事务数量。

NumberOfRolledBackTransactions

long

事务缓冲区中回滚事务的数量。

CommitThroughput

long

事务缓冲区中每秒提交事务的平均数量。

RegisteredDmlCount

long

事务缓冲区中注册的 DML 操作数量。

LagFromSourceInMilliseconds

long

在事务日志中发生变化及其添加到事务缓冲区时的时间差,以毫秒为单位。

MaxLagFromSourceInMilliseconds

long

当在事务日志中发生更改时以及添加到事务缓冲区时之间的最大时间差(以毫秒为单位)。

MinLagFromSourceInMilliseconds

long

当在事务日志中发生更改时以及添加到事务缓冲区时,最小时间差(毫秒)。

AbandonedTransactionIds

string[]

最近加带的事务标识符的数组会因为其年龄从事务缓冲区中删除。详情请参阅 log.mining.transaction.retention.hours

RolledBackTransactionIds

string[]

已最小化并回滚事务缓冲区中的最新事务标识符的数组。

LastCommitDurationInMilliseconds

long

最后一次事务缓冲区提交操作的持续时间,以毫秒为单位。

MaxCommitDurationInMilliseconds

long

最长事务缓冲区提交操作的持续时间,以毫秒为单位。

ErrorCount

int

检测到的错误数量。

WarningCount

int

检测到的警告数量。

ScnFreezeCount

int

系统更改号被检查的时间,并保持不变。高值表示长时间运行的事务正在持续,并阻止连接器将最近处理的系统更改号刷新到连接器的偏移量。当条件最佳时,该值应接近或等于 0。

UnparsableDdlCount

int

已检测到但无法通过 DDL 解析解析器解析的 DDL 记录数量。这应该始终为 0 ;但是,当允许跳过不可解析的 DDL 时,这个指标可用于确定是否将任何警告写入连接器日志中。

MiningSessionUserGlobalAreaMemoryInBytes

long

当前最小会话的用户全局区域(UGA)内存消耗(以字节为单位)。

MiningSessionUserGlobalAreaMaxMemoryInBytes

long

在所有最小会话中,最大最小会话的用户全局区域(UGA)内存消耗(以字节为单位)。

MiningSessionProcessGlobalAreaMemoryInBytes

long

当前最小会话的进程全局区域(PGA)内存消耗(以字节为单位)。

MiningSessionProcessGlobalAreaMaxMemoryInBytes

long

最大最小会话的进程全局区域(PGA)内存消耗(以字节为单位)。

6.7.3. Debezium Oracle 连接器模式历史记录指标

MBeandebezium.oracle:type=connector-metrics,context=schema-history,server= <oracle.server.name>

下表列出了可用的模式历史记录指标。

Expand
属性类型描述

Status

字符串

STOPPED,RECOVERING (从存储中恢复历史记录)之一,RUNNING 描述数据库架构历史记录的状态。

RecoveryStartTime

long

恢复开始的时间(以 epoch 秒为单位)。

ChangesRecovered

long

恢复阶段读取的更改数量。

ChangesApplied

long

恢复和运行时应用的架构更改总数。

MilliSecondsSinceLast​RecoveredChange

long

从历史记录存储中恢复自上次更改以来的毫秒数。

MilliSecondsSinceLast​AppliedChange

long

从上次更改被应用后经过的毫秒数。

LastRecoveredChange

字符串

从历史记录存储中恢复最后一次更改的字符串表示。

LastAppliedChange

字符串

最后一次应用的更改的字符串表示。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat