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] Transactional message escape retry uses 2 ^ n (XOR) instead of exponential backoff, including a zero-delay retry
- [Bug] Pop long-polling: retry topic message with null properties throws NPE in the reput thread and stalls broker-wide dispatch
- [ISSUE #10987] Fix queryMinOffsetInAllGroup deleting consumer offsets from the live offset table
- [ISSUE #10985] Handle exceptional POP revive reads without losing retry
- [Bug] POP revive can lose retry after an asynchronous message-read failure
- [ISSUE #10966] Fix TransactionalOpBatchService busy loop when deleteContext is drained
- fix: Add nullability annotations and fix kotlin-stdlib transitive leak
- [Feature] Support preemptive cancel commands that supersede queued LiteTopic messages
- [Enhancement] Reduce allocation in ExtraInfoUtil POP info parsing and return primitives from numeric getters
- [Enhancement] Avoid per-message MessageDigest lookup and length-only getBytes allocations on the proxy gRPC path
- Docs
- Java not yet supported