Spring Kafka线程池的扩展

dy1byipe  于 2023-10-15  发布在  Apache
关注(0)|答案(1)|浏览(95)

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

相关问题