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/09/11 01:10:48 UTC
[GitHub] [rocketmq-client-go] sdgmf opened a new issue #534: 重启的时候会有大量重复消费
sdgmf opened a new issue #534:
URL: https://github.com/apache/rocketmq-client-go/issues/534
rocketmq consumer 重启的时候会有大量重复消费，并发高的情况下，这个可以通过参数配置避免吗？可以容忍丢失消息。
----------------------------------------------------------------
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-client-go] vongosling closed issue #534: 重启的时候会有大量重复消费
Posted by GitBox <gi...@apache.org>.
vongosling closed issue #534:
URL: https://github.com/apache/rocketmq-client-go/issues/534
----------------------------------------------------------------
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-client-go] sdgmf commented on issue #534: 重启的时候会有大量重复消费
Posted by GitBox <gi...@apache.org>.
sdgmf commented on issue #534:
URL: https://github.com/apache/rocketmq-client-go/issues/534#issuecomment-690815927
目前参数配置
c, err := rocketmq.NewPushConsumer(
consumer.WithGroupName(o.ConsumerGroup),
consumer.WithNameServer(o.NameServer),
consumer.WithMaxReconsumeTimes(0),
consumer.WithPullBatchSize(32),
consumer.WithConsumeMessageBatchMaxSize(1),
consumer.WithAutoCommit(true),
)
----------------------------------------------------------------
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-client-go] sdgmf commented on issue #534: 重启的时候会有大量重复消费
Posted by GitBox <gi...@apache.org>.
sdgmf commented on issue #534:
URL: https://github.com/apache/rocketmq-client-go/issues/534#issuecomment-690815927
目前参数配置
c, err := rocketmq.NewPushConsumer(
consumer.WithGroupName(o.ConsumerGroup),
consumer.WithNameServer(o.NameServer),
consumer.WithMaxReconsumeTimes(0),
consumer.WithPullBatchSize(32),
consumer.WithConsumeMessageBatchMaxSize(1),
consumer.WithAutoCommit(true),
)
----------------------------------------------------------------
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-client-go] vongosling commented on issue #534: 重启的时候会有大量重复消费
Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #534:
URL: https://github.com/apache/rocketmq-client-go/issues/534#issuecomment-696044603
No, data loss is not allowed by design. As to duplicated messages, you could check the FromWhere logic to verify your case.
----------------------------------------------------------------
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-client-go] vongosling commented on issue #534: 重启的时候会有大量重复消费
Posted by GitBox <gi...@apache.org>.
vongosling commented on issue #534:
URL: https://github.com/apache/rocketmq-client-go/issues/534#issuecomment-696044603
No, data loss is not allowed by design. As to duplicated messages, you could check the FromWhere logic to verify your case.
----------------------------------------------------------------
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-client-go] vongosling closed issue #534: 重启的时候会有大量重复消费
Posted by GitBox <gi...@apache.org>.
vongosling closed issue #534:
URL: https://github.com/apache/rocketmq-client-go/issues/534
----------------------------------------------------------------
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