[GitHub] [rocketmq-streams] ni-ze commented on pull request #295: [ISSUE #281]Filter the removeQueues from addQueues when recovering the state

Sat, 10 Jun 2023 04:30:15 -0700 


ni-ze commented on PR #295:
URL: https://github.com/apache/rocketmq-streams/pull/295#issuecomment-1585626577

   @Shuozeli我又重新看了下，产生这个问题的根源貌似是这样：
   
![image](https://github.com/apache/rocketmq-streams/assets/31175234/6d60e0bd-a43e-4383-8671-2d78d7b5de3c)
   
   this.recoverHandler.apply(addQueue, removeQueue)
   将状态从本地移除，但是这时候还没有出发rebalance，会继续从将要被移除的queue里面拉数据。这时候就有问题。
   


-- 
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.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to