Есть ли способ обнаружить задачу FAILED kafka connect

Question

JMX Exporter может экспортировать метрики Prometheus (kafka_connect_task_status), относящиеся к Kafka Connect. JMX Exporter может выставлять любые запущенные / приостановленные задачи коннектора. Однако он не отображает невыполненные задачи, и после сбоя выполняющейся задачи JMX Exporter больше не будет отображать эту задачу. Как мне записать неудавшуюся задачу? Кто-нибудь здесь сталкивался с той же проблемой и сумел получить решение по этому вопросу?

Answer 1

Найдено решение здесь. Добавьте этот шаблон в 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"