[GitHub] [rocketmq] Jaskey edited a comment on issue #1416: deleteSubGroup bug

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

Jaskey edited a comment on issue #1416:
URL: https://github.com/apache/rocketmq/issues/1416#issuecomment-686987969


   这个问题是常见的一个问题了，我们发现还有一个类似问题也类似：
   
   消费者C1组原本监听 A B topic，由于历史原因，后面不再监听B了，假设目前消费进度X。转而让消费者组C2监听了。
   
   这时候B的消息一直进来，但是C1对于B的消费进度是记录了的X的，这时候消息如果进度去到Y。这里有两个问题：
   
   1.实际上，RMQ会认为C1对于topic B是有堆积的（但是实例在线的时候不会显示，实例断线就显示了）
   2.假设A后面又觉得还是需要重新监听topic B，这时候就惨了。一堆堆积的历史消费都会再次消费，而且consumer_from_where并不生效，因为你曾经听过。
   
   建议在更新订阅关系的同时，对于consumer group offset也进行更新
   
   
   @duhenglucky 


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