Kafka发布了大量的指标来监控它的使用情况和健康状况。这包括传入消息速率的指标，请参阅文档中的监视部分。
您的用例通常是通过一个处理度量的工具来实现的，并且能够基于用户定义的查询触发警报。
例如，普罗米修斯处理得很好。您需要设置它，以便将Kafka的度量转发给普罗米修斯（使用https://github.com/prometheus/jmx_exporter). 由于这是一个非常常见的用例，您可以在网上找到数百篇文章来描述如何设置它。jmx导出器还有kafka jmx模式的示例配置。
一旦这些指标在prometheus中，你就可以跨代理聚合它们并设置警报。