Я хочу настроить мониторинг, который проверяет общее количество сообщений в очереди kafka и общее количество сообщений, уже потребляемых штормом. Если разница в тысячах, мне нужно настроить оповещение. Есть ли такой инструмент в наличии или как я его настраиваю?Monitoring storm trident
Capillary отслеживает дельта (как Storm далеко позади от Kafka) каждого раздела, но, похоже, он не поддерживает оповещения. Вы можете выполнять свои собственные оповещения, периодически называя его API.
Вы также можете создать собственную систему оповещения с начала через JMX. Вы можете контролировать Number of messages the consumer lags behind the producer by и предупреждать, когда лага превышают некоторый порог. Для получения дополнительной информации см. 6.6 Monitoring документации Kafka.
Вы можете найти другие инструменты от Kafka ecosystem.