Кафка испускает тонны метрик, которые позволяют контролировать его использование и работоспособность. Сюда входят показатели скорости входящих сообщений, см. Раздел Мониторинг в документации.
Ваш вариант использования обычно достигается с помощью инструмента, который обрабатывает метрики и может запускать оповещения на основе пользовательских запросов.
Например, Прометей справляется с этим очень хорошо. Вам нужно настроить его таким образом, чтобы метрики из Kafka пересылались в Prometheus (используя https://github.com/prometheus/jmx_exporter).. Это очень распространенный вариант использования, в Интернете вы найдете сотни статей, в которых описано, как это настроить. Экспортер JMX имеет образец конфига также для шаблонов Kafka JMX.
Как только показатели находятся в Prometheus, вы можете объединить их по брокерам и настроить Оповещения .