The issue of automatic message retry

[wd-h2]

`err := consumerClient.Subscribe(mounter.topic, consumer.MessageSelector{}, func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) { err := mounter.logic.Execute(msgs) if err != nil { c.svcCtx.Log.Sugar().Errorf("cosumer_topic_msg:%s:err:%s", mounter.topic, err.Error())

        return consumer.ConsumeRetryLater, nil
    }

    return consumer.ConsumeSuccess, nil
})
if err != nil {
    return
}`

consumer.ConsumeRetryLater ：No automatic retry, is there a solution ?

[Anaethelion]

Hello there,

I think you have the wrong library, nothing in the code above fits this repository.

Closing now.