rocketmq 两个线程同时消费一个消息

1.问题描述

线上项目A部署两台机器,每台机器两个实例,订阅同一个topic,消费心跳数据。

(两台机器host1,host2)

运维同事 部署时 有一个实例用root账户重启的, 然后该实例出现两个线程同时消费一个消息的情况,并且后台查看该消费group delay很多。

rocketmq 两个线程同时消费一个消息

图一  host1机器两个实例 一个为root启动

rocketmq 两个线程同时消费一个消息

图二  rocketmq 监控后台  该group共5个消费者 delay 60多万

rocketmq 两个线程同时消费一个消息

图三  host1 实例2(即root启动那个) 日志    显示同时有两个线程消费同一个消息

rocketmq 两个线程同时消费一个消息

图四  其他账号重启后 rocketmq 情况正常