消息堆积一般是消费速度过慢或者消费线程阻塞造成的,建议查看堆栈信息进行排查。

消息队列Kafka版的消息是客户端主动去服务端拉取的,一般来说,因为是批量拉取机制,服务端拉取都不会是消费的瓶颈。

消息堆积一般是消费速度过慢或者消费线程阻塞造成的。

建议打印消费消息的耗时,或者查看堆栈信息以查看线程执行情况。

注意 Java进程可以用Jstack打印消费者进程的堆栈信息。