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 2022/03/26 03:04:44 UTC

[GitHub] [rocketmq] xu-weize opened a new issue #4039: Cluster mode offset issue

xu-weize opened a new issue #4039:
URL: https://github.com/apache/rocketmq/issues/4039


   The RocketMQ version I am using is 4.5.0, and I am asking about progress in a consumer cluster mode:
   
   1. When the consumer synchronizes the offset to the Broker, it randomly selects a Broker (Master or Slave);
     code:
     FindBrokerResult findBrokerResult = this.mQClientFactory.findBrokerAddressInAdmin(mq.getBrokerName()); (MQClientInstance#findBrokerAddressInAdmin);
   
   3. When the consumer starts, it will perform dynamic heavy load to the Broker side to pull and cancel the offset of the consumption point, which is also a randomly selected Broker. So the question is: how to ensure that the pulled offset is the latest consumer synchronized to the Broker? If the pulled Broker offset is 0, doesn't it have to be re-consumed every time?


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

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

[GitHub] [rocketmq] ni-ze commented on issue #4039: Cluster mode offset issue

Posted by GitBox <gi...@apache.org>.
ni-ze commented on issue #4039:
URL: https://github.com/apache/rocketmq/issues/4039#issuecomment-1080110780


   The latest code, in branch develop, submit offset to master broker only.


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

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

[GitHub] [rocketmq] HScarb edited a comment on issue #4039: Cluster mode offset issue

Posted by GitBox <gi...@apache.org>.
HScarb edited a comment on issue #4039:
URL: https://github.com/apache/rocketmq/issues/4039#issuecomment-1086502146


   See #3605, it merged in version 4.9.3


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

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

[GitHub] [rocketmq] HScarb commented on issue #4039: Cluster mode offset issue

Posted by GitBox <gi...@apache.org>.
HScarb commented on issue #4039:
URL: https://github.com/apache/rocketmq/issues/4039#issuecomment-1086502146


   See #3605 


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

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