zcsh0721 commented on issue #2737:
URL: https://github.com/apache/rocketmq/issues/2737#issuecomment-803214415
@maixiaohai 在 consume 是集群模式下, 执行 `unsubscribe()`, 会导致本来由该 consume
消费的队列,不消费了,且其他同 consumeGroup 下的 consume 也不会消费这个队列; 例如:
topic 有 4 个队列; 一个 consumeGroup ,两个消费者 consumeA consumeB;
consumeA 消费队列 0,1;
consumeB 消费队列 2,3;
当 consumeA 执行 `unsubscribe()`时, 虽然 consumeA 不消费了,但是 consumeB 也消费不了 2,3;
因为集群模式下,消费者的消费队列策略是根据 topic 和 consumeGroup 来分配的, 不论你有没有订阅相同主题,都会占着相同的位置;
所以 `unsubscribe()` 可以解决客户端压力过大,停止消费, 但是会带来相应队列没有其他 consume 处理的问题;
--
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:
[email protected]
