rocketmq
https://github.com/apache/rocketmq
Java
Mirror of Apache RocketMQ
Triage Issues!
When you volunteer to triage issues, you'll receive an email each day with a link to an open issue that needs help in this project. You'll also receive instructions on how to triage issues.
Triage Docs!
Receive a documented method or class from your favorite GitHub repos in your inbox every day. If you're really pro, receive undocumented methods or classes and supercharge your commit history.
Java not yet supported3 Subscribers
Add a CodeTriage badge to rocketmq
Help out
- Issues
- [Bug] Timer enqueue retry re-enqueues already-succeeded requests, delivering scheduled messages multiple times
- [ISSUE #11047] Retry only failed timer requests so succeeded ones are not enqueued twice
- [Bug] Proxy gRPC batch send returns one receipt for N messages, so SDKs fail the send although the broker stored the batch
- [ISSUE #11049] Return one send receipt entry per message for proxy batch sends
- fix: record send-failure cause in requestFail and log write failures
- [ISSUE #10989] Fix transactional escape retry backoff
- [ISSUE #11010] Preserve channel write failure cause
- [ISSUE #11013] Stop timer WAL scheduler during RocksDB shutdown
- [ISSUE #10987] Preserve offsets during correction query
- [ISSUE #10990] Avoid NPE for retry messages without properties
- Docs
- Java not yet supported