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 #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
- [Enhancement] Add Nullable annotations to nullable Message getters and fix kotlin-stdlib transitive leak
- [Enhancement][Discussion] Cache serialized topic route data in NameServer getRouteInfoByTopic
- Docs
- Java not yet supported