apache / apache/eventmesh

[Enhancement] Consummate the functionality of RocketMQ based retry strategy under grpc and tcp protocols

Open
#4,555 3 comments 1 reaction 0 assignees View on GitHub
enhancement help wanted
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

Open the contributing 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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.