消息队列快速处理积压的消息
2023-07-03 12:00:29 5 举报消息队列快速处理积压的消息
作者其他创作
大纲/内容
消费者
假设一个消费者一秒处理500条数据，三个消费者一秒1500，一分钟是9万条，一小时540万，处理完积压的消息可能需要一小时
partition2
MQ
partition30
生产者
partition1
消费者重启，可以正常消费，怎么将快速积压的几百万消息处理掉
partition3
消费者故障积压了几百万的数据
临时申请30个机器去消费，3个消费者可能需要1小时消费完的数据，30个消费者几分钟可以处理完
新建一个topic，设置30个partition
将消费者处理数据的逻辑改成往新topic里写消息
0 条评论
下一页
