JMX配置示例：采集Snowflake Kafka Connector专属MBean指标

以下配置适配部署了Snowflake Kafka Connector的Kafka Connect集群，完全兼容你已正常采集的Kafka Connect原生指标，补充了Snowflake Connector专属MBean的匹配规则。

配置注意事项 #

• Snowflake Connector的MBean对象命名格式为snowflake.kafka.connector:connector=connector_name,pipe=pipe_name,category=category_name,name=metric_name，配置中会自动提取四个属性作为指标标签
• 规则兼容MBean属性顺序差异，避免因为不同版本Connector属性排列顺序不同导致的漏采问题
• 部分低版本Snowflake Kafka Connector默认关闭MBean注册，需要在Connector任务配置中添加参数"snowflake.jmx.metrics.enabled": "true"，重启任务后才会上报对应指标

完整JMX Exporter配置样例 #

（以Prometheus JMX Exporter采集场景为例）

# JMX连接基础配置
startDelaySeconds: 0
sslEnabled: false
jmxUrl: service:jmx:rmi:///jndi/rmi://127.0.0.1:9999/jmxrmi # 替换为当前Kafka Connect节点的实际JMX监听地址
lowercaseOutputName: true
lowercaseOutputLabelNames: true

rules:
  # 此处保留你已经验证生效的所有原生Kafka Connect、Kafka、JVM指标采集规则
  - pattern: kafka.connect.*
    name: kafka_connect_metrics
    type: GAUGE
    # 原有规则的标签提取逻辑保持不变即可

  # Snowflake Kafka Connector专属指标采集规则
  - pattern: 'snowflake.kafka.connector<connector=(.+), pipe=(.+), category=(.+), name=(.+)><>(.+):'
    name: snowflake_kafka_connector_$5
    labels:
      connector: "$1"
      pipe: "$2"
      category: "$3"
      metric_attribute: "$4"
    type: GAUGE

  # 兼容MBean属性顺序不一致的兜底规则
  - pattern: 'snowflake.kafka.connector<name=(.+), category=(.+), connector=(.+), pipe=(.+)><>(.+):'
    name: snowflake_kafka_connector_$5
    labels:
      connector: "$3"
      pipe: "$4"
      category: "$2"
      metric_attribute: "$1"
    type: GAUGE

验证步骤 #

• 替换配置后重启Kafka Connect进程，加载新的JMX Exporter配置
• 访问JMX Exporter默认暴露的http://<connect节点IP>:9404/metrics端点，搜索snowflake_kafka_connector前缀的指标，确认指标和对应标签正常输出
• 如果无对应指标，可先通过JConsole连接Kafka Connect的JMX端口，确认MBean列表中存在snowflake.kafka.connector域名下的对象，排除Connector本身未上报指标的问题

内容的提问来源于stack exchange，提问作者carao