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 #D18] Discard timer messages with malformed real topic or queue id in convertMessage
- [ISSUE #D19] Tolerate null pull result when checking half messages
- [D20] Guard broker processors against requests whose body decodes to null
- fix(client): return the configured total batch max bytes from ProduceAccumulator
- fix(client): compare pop consume RT against the invisible time in milliseconds
- fix(client): clamp the pop retry delay level when a message is younger than the first level
- fix(common): make MessageQueueAssignment equals consistent with hashCode
- fix(common): keep '=' inside attribute values when parsing modifications
- fix(common): fall back to the higher version for negative version values
- fix(tools): stop -c <cluster> from switching resetOffsetByTime to the C++ protocol
- Docs
- Java not yet supported