分布式消息服务Kafka

消费阻塞以及堆积

2024-05-08 08:58:21

消费端最常见的问题就是消费堆积,最常造成堆积的原因是:

(1)消费速度跟不上生产速度,此时应该提高消费速度,详见下一节《提高消费速度》。

(2)消费端产生了阻塞。

消费端拿到消息后,执行消费逻辑,通常会执行一些远程调用,如果这个时候同步等待结果,则有可能造成一直等待,消费进程无法向前推进。

消费端应该竭力避免堵塞消费线程,如果存在等待调用结果的情况,建议设置等待的超时时间,超时后作消费失败处理。


qs43lLXma66k