出现堆积一般是消息消费速率小于了生产速率,可以通过控制台的group消费状态进行查看,详情
查看消费状态。
可以通过提升消费能力的方式来缓解。提高消费速度提高消费速度有以下两个办法:
增加Consumer实例个数。可以在进程内直接增加(需要保证每个实例对应一个线程,否则没有太大意义),也可以部署多个消费实例进程;需要注意的是,实例个数超过分区数量后就不再能提高速度,将会有消费实例不工作。增加消费线程。
增加Consumer实例本质上也是增加线程的方式来提升速度,因此更加重要的性能提升方式是增加消费线程,最基本的步骤如下:定义一个线程池,Poll数据。把数据提交到线程池进行并发处理。等并发结果返回成功后,再次poll数据执行。