shirenchuang opened a new issue, #7337:
URL: https://github.com/apache/rocketmq/issues/7337
### Before Creating the Enhancement Request
- [X] I have confirmed that this should be classified as an enhancement
rather than a bug/feature.
### Summary
ConsumeMessageConcurrentlyService#start
```java
public void start() {
this.cleanExpireMsgExecutors.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
try {
cleanExpireMsg();
} catch (Throwable e) {
log.error("scheduleAtFixedRate cleanExpireMsg
exception", e);
}
}
// 这里的间隔时间改成1或者 5 分钟比较合适
}, this.defaultMQPushConsumer.getConsumeTimeout(),
this.defaultMQPushConsumer.getConsumeTimeout(), TimeUnit.MINUTES);
}
```
这里最坏情况 可能会让过期的消息超过 2* this.defaultMQPushConsumer.getConsumeTimeout() 未被清理；
建议改成1分钟或者3分钟之类的；
The worst case scenario here may cause expired messages to exceed 2*
this.defaultMQPushConsumer.getConsumeTimeout() and not be cleared; it is
recommended to change it to 1 minute or 3 minutes or something;
### Motivation
.
### Describe the Solution You'd Like
.
### Describe Alternatives You've Considered
.
### Additional Context
_No response_
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
