yaphetsglhf opened a new issue #650:
URL: https://github.com/apache/rocketmq-client-go/issues/650
we try to use the orderly consumer, but when we return the
`SuspendCurrentQueueAMoment` , we found the message will not be reconsumed
again.
Another problem is that when we send another message which commit
`ConsumeSuccess`, all the messages including the blocked ones will commited
all at once, which will lead to message missing.
how to init the consumer :
```
c.consumer, err = rocketmq.NewPushConsumer(
consumer.WithGroupName(c.GroupName),
consumer.WithNsResolver(primitive.NewPassthroughResolver([]string{config.ENV.MQConnectionString})),
consumer.WithConsumerModel(consumer.Clustering),
consumer.WithConsumeFromWhere(consumer.ConsumeFromFirstOffset),
consumer.WithConsumerOrder(true),
consumer.WithMaxReconsumeTimes(5),
)
```
--
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]
