有没有办法检测 FAILED kafka connect 任务

Posted 2023-02-15

【中文标题】有没有办法检测 FAILED kafka connect 任务

【英文标题】：Is there a way to detect the FAILED kafka connect task

【发布时间】：2019-12-09 14:21:23

【问题描述】：

JMX 导出器能够导出有关 Kafka Connect 的 Prometheus 指标 (kafka_connect_task_status)。 JMX Exporter 能够公开任何正在运行/暂停的连接器任务。 但是，它不会显示任何失败的任务，并且一旦正在运行的任务失败，JMX 导出器将不再公开该任务。 如何捕获失败的任务？ 这里有没有人遇到过同样的问题并设法解决了这个问题？

【问题讨论】：

您找到解决方案了吗？

【参考方案1】：

找到解决方案here。将此模式添加到 kafka-connect。它将状态的字符串值转为标签，并添加一个常量值 1。

      - pattern: 'kafka.connect<type=connector-task-metrics, connector=(.+), task=(.+)><>status: (.+)'
    name: kafka_connect_task_status
    value: 1
    labels:
      connector: "$1"
      task: "$2"
      status: "$3"