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
- [ISSUE #11433] Keep suspended lite long-polling requests reachable when their queue leaves pollingMap
- [ISSUE #11435] Log the consumer group in preCheck when the lite parent topic does not exist
- [Bug] The SQL92 selector parser ignores trailing tokens, so a malformed filter silently drops clauses instead of failing
- [ISSUE #11437] fix(filter): reject selectors that have trailing tokens
- [Bug] A compaction round interrupted in the scratch folder splices stale bytes into the live compaction log of the next round
- [ISSUE #11439] fix(store): start compaction rounds from an empty scratch folder
- [Bug] notifyMasterOnline aborts the long-polling wake-up with a NullPointerException when an arrival drains a bucket first
- [ISSUE #11441] fix(broker): wake the held pull requests when an arrival drained one bucket
- feat: add mqadmin batch commands for deleting topics and subscription groups
- [Bug] compressedRegister=true makes broker registration fail: the register body is compressed but the header says it is not
- Docs
- Java not yet supported