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 #11039] Track consumer group channel attribute for heartbeat-v2 withoutSub registration
- [ISSUE #11041] Fix off-by-one in paginated metadata sync dropping the last entry
- fix: keep pop ack effective when cleanup has staged the checkpoint for its store write
- [ISSUE #11043] Skip stale channel-destroy unregister when the broker re-registered
- [ISSUE #11013] Stop MessageRocksDBStorage flush scheduler on shutdown
- [Bug] MessageRocksDBStorage accumulates timer-WAL flush tasks after reload
- [ISSUE #11003] Reduce allocations in hot-path request headers' toString()
- [Enhancement] Avoid per-message getBytes() for topic and CRC32 property key on the broker write path
- [Enhancement] Reduce allocations in hot-path request headers' toString() by replacing Guava MoreObjects.toStringHelper
- [Bug] Send-failure cause is discarded: requestFail() never records f.cause()
- Docs
- Java not yet supported