我的想法是 机器配置上:增加分区 partition ,增加组内 consumer ,并最好让分区跟 consumer 数量比例为 1:1 代码上:一般消息堆积都是 consumer 消费逻辑里有长时间 I/O 行为导致,所以可以在 consumer 中开启多线程消费 面试官反问:还有其他方法吗? 还有,如果我想这个分区的消息都可以顺序消费,开启多线程怎么保证顺序消费? 如何回答? consumer, 分区, 线程, 消费
只用增加 partition 就完事吧, 得注意增加 partition 时, 会暂时性打乱消息顺序. 因为上面这个原因, 所以最好 partition 数量在一开始时就多设置一点 后面消息堆积时, 就只能增加 consumer 就好了 代码上建议保持原样或者缩短长 IO 行为, 不必要引入多线程来增加复杂度