[GitHub] [rocketmq] wenfei4 opened a new issue #1440: Broker重启后重复消费消息

[GitBox <gi...@apache.org>]

wenfei4 opened a new issue #1440: Broker重启后重复消费消息
URL: https://github.com/apache/rocketmq/issues/1440
 
 
   **BUG REPORT**
   
   在主从模式下，将主从角色调换后，消费者消费到了历史消息（12小时之前的）。
   * 版本：4.2.0
   * 部署模式: 集群模式，共4台服务器b1-b4:
       * Broker A: MasterA(b1), SlaveA(b2)
       * Broker B: MasterB(b3), SlaveB(b4)
   
   - What did you do (The steps to reproduce)?
   
   1. shutdown MasterA(b1)
   2. wait for 30 minutes
   3. shutdown SlaveA(b2)
   4. modify b2 set brokerId=0
   5. restart b2(as Master)
   6. everything be ok
   7. after 12 hours, modify b1 set  brokerId=1 and startup b1(as Slave)
   8. after b1 sync data from b2, shutdown b2
   9. wait for 5 minutes
   10. shutdown b1
   11. modify b1 set  brokerId=0 and startup b1(as Master)
   12. then all consumers are consuming history messages(about 12 hours ago),and a lot of pressure on b1
   
   - What did you expect to see?
   
   - What did you see instead?
   
   2. Please tell us about your environment:
   
   3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc):

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services