我们正在使用Prometheus和Grafana监控我们的Kafka集群。
在我们的应用程序中,我们使用Kafka streams,由于异常的原因,可能会出现Kafka stream停止的情况。我们记录了事件setUnCaughtExceptionHandler,但是当流停止时,我们还需要某种类型的警报。
目前我们有一个运行为代理的jmx_exporter,并通过一个端点公开Kafka指标,Prometheus从该端点获取指标。
我们没有看到任何给出每个主题活动消费者数量的指标。我们是否遗漏了什么?有关如何获取活动消费者数量并在消费者停止时发送警报的建议。
在我们的应用程序中,我们使用Kafka streams,由于异常的原因,可能会出现Kafka stream停止的情况。我们记录了事件setUnCaughtExceptionHandler,但是当流停止时,我们还需要某种类型的警报。
目前我们有一个运行为代理的jmx_exporter,并通过一个端点公开Kafka指标,Prometheus从该端点获取指标。
我们没有看到任何给出每个主题活动消费者数量的指标。我们是否遗漏了什么?有关如何获取活动消费者数量并在消费者停止时发送警报的建议。