Sink 监控

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

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

JMX 指标 在 5.3.0 中引入

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

  • 对象名： 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。