GitHub user ShadowySpirits added a comment to the discussion: Create subscriptionGroup through the command line and set the maximum number of retries for retryMaxTimes, which does not take effect:RocketMQ4.9.4
According to the java doc of `DefaultMQPushConsumer#maxReconsumeTimes`, maxReconsumeTimes has a default value of -1, which translates to 16 in concurrent mode. This strategy is implemented on the client side. https://github.com/apache/rocketmq/blob/37ff93a27b034b2184144798d6c9f5bd00d63215/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java#L867-L874 It is better to obey the subscription group config in the server when maxReconsumeTimes is not set by the user. However, given compatibility issues, we need more discussion. GitHub link: https://github.com/apache/rocketmq/discussions/6370#discussioncomment-5341072 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
