[BUG] 使用 pushconsumer 客户端，默认重试两次后就commit，消息状态变成consumed

[majintao]

pushConsumer 一直return consumer.ConsumeRetryLater，就只重试两次，然后就在admin后台查看变成了consumed 已消费状态

核心代码

    	topic := "GO_TEST_TOPIC"
	rocket_mq.NewConsumerProcessor(topic, func(c context.Context, msg []byte) error {
		xflog.Infof("msg:%v", string(msg))
		return errors.New("111")
	}, consumer.WithConsumerModel(consumer.Clustering),
		consumer.WithMaxReconsumeTimes(16),
		consumer.WithGroupName("TEST_GROUP_4"),
		consumer.WithNameServer([]string{"127.0.0.1:9876"})).Start()






	c.Subscribe(cp.topic, cp.selector, func(ctx context.Context, messages ...*primitive.MessageExt) (
		consumer.ConsumeResult, error) {
		// 处理消息
		for _, message := range messages {
			err := cp.process(ctx, message) // 业务处理
			if err != nil {
				fmt.Printf("messageId:%s, consumer times:%d", message.MsgId, message.ReconsumeTimes)
				concurrentCtx, _ := primitive.GetConcurrentlyCtx(ctx)
				concurrentCtx.DelayLevelWhenNextConsume = 2 // only run when return consumer.ConsumeRetryLater
				return consumer.ConsumeRetryLater, nil
			}
		}
		return consumer.ConsumeSuccess, nil
	})

[majintao]

@twz915

[caichunlong]

@twz915

[twz915]

我测试了，工作正常，和预期一致。你可以检查一下 rocketmq 服务端有没有什么设置只允许重试两次。
比如 broker.conf 文件，messageDelayLevel，maxReconsumeTimes 参数之类的

我使用的版本是 master 分支