[Enhancement] Consummate the functionality of RocketMQ based retry strategy under grpc and tcp protocols
- Dominant language
- Java
- Stars
- 1.8k
- Forks
- 658
- Avg merge
- 11h 29m
- Merged PRs (30d)
- 52
Description
### Search before asking
- [X] I had searched in the [issues](https://github.com/apache/eventmesh/issues?q=is%3Aissue) and found no similar issues.
### Enhancement Request
For the case of message consumption failure, the retry strategy implemented by EventMesh based on RocketMQ currently fully supports the HTTP protocol running mode of EventMesh, and the retry under the grpc and tcp protocols is waiting to be consummated.
对于消息消费失败的情况,目前EventMesh基于RocketMQ实现的重试策略,完整地支持EventMesh的http协议运行方式,grpc协议和tcp协议下的这种重试等待完善。
### Describe the solution you'd like
task list
- [ ] Consummate the functionality of RocketMQ based retry strategy under grpc protocol
- [ ] Consummate the functionality of RocketMQ based retry strategy under tcp protocol
Welcome to claim the task you are interested in and create corresponding sub issue.
### Are you willing to submit PR?
- [ ] Yes I am willing to submit a PR!
### Code of Conduct
- [ ] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) *
Contributor guide
Research direction
Start by tracing the existing RocketMQ-based retry strategy for EventMesh's HTTP protocol, then compare the gRPC and TCP message-consumption paths. The work is done when failed consumption has equivalent retry behavior under both gRPC and TCP, with corresponding verification in the project's tests.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- grpc, java
- Domain
- backend, distributed-systems
- Issue type
- Feature
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 30/100