源监控

Neo4j Kafka 连接器源为 变更数据捕获策略 提供 JMX 指标，以帮助您监控数据摄取过程的状态。

JMX 指标不会通过官方的 Kafka Connect 接口收集，也不会由通过 metric.reporters Kafka Connect 设置定义的报告器上报。要使用这些指标，您必须使用兼容 JMX 的监控工具或代理。

JMX 指标 Introduced in 5.3.0

以下 JMX 指标可用于 CDC 源连接器实例

  • 对象名称: kafka.connect:type=plugins,connector={CONNECTOR_NAME},task={TASK_ID}

属性 类型 描述

last_cdc_tx_commit_timestamp

Number

连接器轮询的最近一次已提交 CDC 事务的时间戳。

last_cdc_tx_start_timestamp

Number

连接器轮询的最近一次 CDC 事务开始的时间戳。

last_cdc_tx_id

Number

连接器轮询的最近一次 CDC 事务的 ID。

last_db_tx_id

Number

数据库中最近一次事务的 ID。仅当通过 neo4j.cdc.metric.last-db-tx-id.enabled 属性启用时才报告此指标。

last_db_tx_id 指标会定期刷新，可能会落后于实际的数据库事务状态，这取决于配置的 neo4j.cdc.metric.last-tx-id.refresh-interval 设置。

配置

要启用 last_db_tx_id 指标，需要在源实例中配置以下属性

名称 类型 描述

neo4j.cdc.metric.last-db-tx-id.enabled

布尔值

是否启用 last_db_tx_id 指标。

默认值：false Introduced in 5.3.0

neo4j.cdc.metric.last-db-tx-id.refresh-interval

Duration

last_db_tx_id 指标的刷新间隔（有效单位有：ms、s、m、h 和 d；默认单位为 s）。

默认值：30s Introduced in 5.3.0