搜索

7.7. 监控 Debezium Oracle 连接器性能

download PDF

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

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

7.7.1. Debezium Oracle 连接器快照指标

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

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

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

属性类型描述

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

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

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

属性类型描述

ChunkId

字符串

当前快照块的标识符。

ChunkFrom

字符串

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

ChunkTo

字符串

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

TableFrom

字符串

当前快照表的主密钥集的下限。

TableTo

字符串

当前快照表的主密钥集的上限。

7.7.2. Debezium Oracle 连接器流指标

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

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

属性类型描述

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 连接器还提供以下额外流指标:

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

CurrentScn

BigInteger

最近处理的系统更改号。

OldestScn

BigInteger

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

CommittedScn

BigInteger

最后提交的系统更改来自事务缓冲区的编号。

OffsetScn

BigInteger

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

CurrentRedoLogFileName

string[]

当前 mined 的日志文件数组。

MinimumMinedLogCount

long

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

MaximumMinedLogCount

long

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

RedoLogStatus

string[]

每个 mined 日志文件的当前状态数组,格式为 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

连接器在从日志减减视图中获取另一批处理结果前休眠的毫秒数。

MaxBatchProcessingThroughput

long

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

AverageBatchProcessingThroughput

long

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

LastBatchProcessingThroughput

long

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

NetworkConnectionProblemsCounter

long

检测到的连接问题的数量。

HoursToKeepTransactionInBuffer

int

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

NumberOfActiveTransactions

long

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

NumberOfCommittedTransactions

long

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

NumberOfRolledBackTransactions

long

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

CommitThroughput

long

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

RegisteredDmlCount

long

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

LagFromSourceInMilliseconds

long

事务日志中发生更改时以及添加到事务缓冲区的时间差异(毫秒)。

MaxLagFromSourceInMilliseconds

long

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

MinLagFromSourceInMilliseconds

long

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

AbandonedTransactionIds

string[]

最新取消的事务标识符的数组,因为其年龄从事务缓冲区中删除。详情请参阅 log.mining.transaction.retention.ms

RolledBackTransactionIds

string[]

在事务缓冲区中重试并回滚的最新事务标识符的数组。

LastCommitDurationInMilliseconds

long

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

MaxCommitDurationInMilliseconds

long

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

ErrorCount

int

检测到的错误数量。

WarningCount

int

检测到的警告数量。

ScnFreezeCount

int

检查系统更改号以提前检查的次数,并保持不变。高值可以表示长期运行的事务正在进行,并阻止连接器刷新最近处理的系统更改号到连接器的偏移。当条件最佳时,该值应接近或等于 0。

UnparsableDdlCount

int

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

MiningSessionUserGlobalAreaMemoryInBytes

long

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

MiningSessionUserGlobalAreaMaxMemoryInBytes

long

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

MiningSessionProcessGlobalAreaMemoryInBytes

long

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

MiningSessionProcessGlobalAreaMaxMemoryInBytes

long

所有 mining 会话的最大 mining 会话全局区域(PGA)内存消耗(以字节为单位)。

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

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

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

属性类型描述

Status

字符串

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

RecoveryStartTime

long

恢复启动时的 epoch 秒的时间(以秒为单位)。

ChangesRecovered

long

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

ChangesApplied

long

恢复和运行时期间应用的模式更改总数。

MilliSecondsSinceLast​RecoveredChange

long

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

MilliSecondsSinceLast​AppliedChange

long

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

LastRecoveredChange

字符串

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

LastAppliedChange

字符串

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

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

© 2024 Red Hat, Inc.