应用扩容导致的mq消息积压和重发消费问题

2021-01-07  本文已影响0人  luncene_e110

背景:

   为应对元旦促销活动,导致的突发流量,决定对应用进行扩容,新增多个节点。

现象:

根据topic来看,queue没有分配均匀,有没有被分配consumer的queue,消费的模式是cluster

且根据应用日志查看,发现有消息被多台应用同时消费间隔。

根据代码核实:consumer在注册到broker的时候,是用broker的ip@进程号来做为clientId的,我们应用扩容时,docker的内部的ip都是一样的,然后每个应用的进程号都为1,导致broker无法区分client,在client端做reblance的时候也会出现问题。

上一篇下一篇

猜你喜欢

热点阅读