does the maxReconsumeTimes config really work?

[rickyEI]

i have config maxReconsumeTimes like below:

spring.cloud.stream.rocketmq.bindings.direct-in.consumer.push.maxReconsumeTimes = 2

anyway, it didn't work at all. Rocketmq still reconsume 16 times before sending message to dlq.
I cann't find config about setting 'maxReconsume' to DefaultMQPushConsumer either.

com.alibaba.cloud.stream.binder.rocketmq.integration.inbound.RocketMQConsumerFactory#initPushConsumer, here i find setting a DefaultMQPushConsumer. But i didn't find the initPushConsumer() method setting the maxReconsume to DefaultMQPushConsumer.

[yuhuangbin]

Welcome to contribute，refer: RocketMQConsumerFactory

[misselvexu]

i will finish it 。

[Sorieee]

Subscribed

[Sorieee]

Plz try spring.cloud.stream.bindings.[destinationName].consumer.maxAttempts.

[Sorieee]

Plz try spring.cloud.stream.bindings.[destinationName].consumer.maxAttempts.

maxAttempts is a client behavior, maxReconsumeTimes maybe a server behavior

[misselvexu]

Plz try spring.cloud.stream.bindings.[destinationName].consumer.maxAttempts.

maxAttempts is a client behavior, maxReconsumeTimes maybe a server behavior

Copy that，

[dyrnq]

@yuhuangbin 2023.x branch missing this too.