You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2019/09/18 09:40:52 UTC

[GitHub] [rocketmq] 821320945 commented on issue #1416: deleteSubGroup bug

821320945 commented on issue #1416: deleteSubGroup bug
URL: https://github.com/apache/rocketmq/issues/1416#issuecomment-532607625
 
 
   
   
   
   > 
   > 
   > > > @RongNanNan @duhenglucky Resolved [PR](https://github.com/apache/rocketmq/pull/1417)
   > > 
   > > 
   > > 兄弟 你确定new ConsumerOffsetManager()好使吗 new出来的对象offsetTable难道不是空的吗
   > 
   > Oh Yes of course
   > This Is have some problems....I haven't finished yet
   > I didn't consider before the cleanup that the client deleted the group from broker or namerSrv.
   > Recently make some changes and deal with it ...
   > THX for U attention, welcome U to join.
   可以尝试下这么写, 从broker中获取ConsumerOffsetManager
     ConsumerOffsetManager clean = brokerController.getConsumerOffsetManager();

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