分布式消息服务Kafka

增加消费线程

2022-08-25 09:33:45

增加 Consumer 实例本质上也是增加线程的方式来提升速度,因此更加重要的性能提升方式是增加消费线程,最基本的步骤如下:

(1)定义一个线程池;

(2)Poll 数据;

(3)把数据提交到线程池进行并发处理;

(4)等并发结果返回成功后,再次 poll 数据执行。

RiTrC4JtrTf7