Перейти к основному содержимому

Проверка Kafka

Проверка Kafka создаётся в дашборде, выполняет её агент на вашем хосте. Чекер лёгкий: он делает TCP-connect к каждому bootstrap-брокеру и падает, только если недоступны все. Consumer-lag и метрики брокеров этот чекер не собирает.

Предварительные требования​

  • Агент Flaree установлен и в статусе Online.
  • Тариф Pro: проверки брокеров недоступны на Starter.
  • Сетевая доступность от хоста агента до bootstrap-брокеров (обычно TCP 9092, при TLS — 9093).
  • Учётные записи и ACL не нужны: проверка ограничивается TCP-соединением и не выполняет Kafka-протокольных запросов.

Минимальная конфигурация​

Локальный agent.yaml для этой проверки менять не нужно. В дашборде: Агенты → ваш агент → Назначенные проверки → Новая проверка, тип kafka, конфиг:

{ "bootstrapServers": "kafka-0:9092" }

Полная конфигурация​

{ "bootstrapServers": "kafka-0:9092,kafka-1:9092,kafka-2:9092" }
КлючТипПо умолчаниюОписание
bootstrapServersstring—Список брокеров host:port через запятую. Обязателен.

Семантика результата:

  • Все брокеры доступны — проверка успешна.
  • Часть брокеров недоступна — проверка успешна с пометкой partial_brokers_unreachable и списком ошибок в результате.
  • Все брокеры недоступны — проверка падает с all_brokers_unreachable.

Перечисляйте все брокеры кластера, а не один: так падение отдельного брокера видно по пометке в результатах, а инцидент открывается только при полной недоступности.

Таймаут задания применяется к каждому TCP-connect отдельно; интервал и таймаут настраиваются в форме дашборда.

Проверка работы​

  • Проверьте TCP-доступность брокера с хоста агента.
  • Убедитесь, что счётчик проверок с type="kafka" растёт на локальных метриках агента.
  • В дашборде компонент перейдёт в Operational в течение одного-двух интервалов.
# TCP-connect до брокера (bash / nc)
nc -zv kafka-0 9092

# Счётчик проверок на агенте
curl -s http://127.0.0.1:9090/metrics | grep 'type="kafka"'
# flaree_agent_checks_total{type="kafka",ok="true"} 6

Troubleshooting​

  • Данные не появляются — чек-лист нет данных.
  • invalid_format в ошибке — элемент списка не в виде host:port (например, забыт порт).
  • all_brokers_unreachable — firewall между хостом агента и брокерами либо брокеры слушают только внутренний интерфейс (advertised.listeners).
к сведению

Проверка отвечает на вопрос «жив ли порт брокера», а не «здоров ли кластер». Для метрик consumer-lag подключите экспорт из вашего Kafka-стека через OTLP.

Связанные страницы: RabbitMQ · OTLP · концепция агента.