You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by "ni-ze (via GitHub)" <gi...@apache.org> on 2023/06/10 11:30:11 UTC

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

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: commits-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org