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 2020/05/28 02:00:20 UTC
[GitHub] [rocketmq] githubyangxd opened a new issue #2049: pull方式消费，应用集群、mq集群如何管理offset
githubyangxd opened a new issue #2049:
URL: https://github.com/apache/rocketmq/issues/2049
pull模式，应用集群，mq集群，怎么处理offset比较好，初步了解到使用RemoteBrokerOffsetStore，但是疑惑存储在本地的偏移量，因为应用是集群环境导致“各个本地”存储的offset乱套了。
----------------------------------------------------------------
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
[GitHub] [rocketmq] githubyangxd commented on issue #2049: pull方式消费，应用集群、mq集群如何管理offset
Posted by GitBox <gi...@apache.org>.
githubyangxd commented on issue #2049:
URL: https://github.com/apache/rocketmq/issues/2049#issuecomment-635859068
>
>
> > pull模式，应用集群，mq集群，怎么处理offset比较好，初步了解到使用RemoteBrokerOffsetStore，但是疑惑存储在本地的偏移量，因为应用是集群环境导致“各个本地”存储的offset乱套了。
>
> Use LocalFileOffsetStore or RemoteBrokerOffsetStore depends on consumer's MessageModel. If BROADCASTING, use LocalFileOffsetStore, if CLUSTERING, use RemoteBrokerOffsetStore.
是否有案例，不需要分布式锁吗
----------------------------------------------------------------
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
[GitHub] [rocketmq] githubyangxd commented on issue #2049: pull方式消费，应用集群、mq集群如何管理offset
Posted by GitBox <gi...@apache.org>.
githubyangxd commented on issue #2049:
URL: https://github.com/apache/rocketmq/issues/2049#issuecomment-635858608
和网上云云一样，回答不到点上
----------------------------------------------------------------
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
[GitHub] [rocketmq] vongosling closed issue #2049: pull方式消费，应用集群、mq集群如何管理offset
Posted by GitBox <gi...@apache.org>.
vongosling closed issue #2049:
URL: https://github.com/apache/rocketmq/issues/2049
----------------------------------------------------------------
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
[GitHub] [rocketmq] lizhiboo commented on issue #2049: pull方式消费，应用集群、mq集群如何管理offset
Posted by GitBox <gi...@apache.org>.
lizhiboo commented on issue #2049:
URL: https://github.com/apache/rocketmq/issues/2049#issuecomment-635095674
> pull模式，应用集群，mq集群，怎么处理offset比较好，初步了解到使用RemoteBrokerOffsetStore，但是疑惑存储在本地的偏移量，因为应用是集群环境导致“各个本地”存储的offset乱套了。
Use LocalFileOffsetStore or RemoteBrokerOffsetStore depends on consumer's MessageModel. If BROADCASTING, use LocalFileOffsetStore, if CLUSTERING, use RemoteBrokerOffsetStore.
----------------------------------------------------------------
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
[GitHub] [rocketmq] githubyangxd commented on issue #2049: pull方式消费，应用集群、mq集群如何管理offset
Posted by GitBox <gi...@apache.org>.
githubyangxd commented on issue #2049:
URL: https://github.com/apache/rocketmq/issues/2049#issuecomment-635858974
是否有案例，不需要分布式锁吗
----------------------------------------------------------------
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
[GitHub] [rocketmq] githubyangxd removed a comment on issue #2049: pull方式消费，应用集群、mq集群如何管理offset
Posted by GitBox <gi...@apache.org>.
githubyangxd removed a comment on issue #2049:
URL: https://github.com/apache/rocketmq/issues/2049#issuecomment-635858974
是否有案例，不需要分布式锁吗
----------------------------------------------------------------
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