我想使用org.springframework.cloud:spring-cloud-stream-binder-kafka
检测处理消费Kafka事件的线程池。确定使用率的百分比是非常有用的,这样我们就可以在可能无法使用所有可用消息时得到指示。
是的,当我们不再能够处理所有可用消息时,我可以使用消费者延迟来创建警报,但我希望在此之前创建警报,这样我们就可以增加线程池并在它发生之前避免它。
到目前为止,我在文档中找不到任何有用的东西。有没有一种方法可以用千分尺来确定这样的度量?
我想使用org.springframework.cloud:spring-cloud-stream-binder-kafka
检测处理消费Kafka事件的线程池。确定使用率的百分比是非常有用的,这样我们就可以在可能无法使用所有可用消息时得到指示。
是的,当我们不再能够处理所有可用消息时,我可以使用消费者延迟来创建警报,但我希望在此之前创建警报,这样我们就可以增加线程池并在它发生之前避免它。
到目前为止,我在文档中找不到任何有用的东西。有没有一种方法可以用千分尺来确定这样的度量?
1条答案
按热度按时间cgh8pdjw1#
如果我理解正确的话,
ExecutorServiceMetrics
可能会有帮助。