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 #11423] fix(proxy): report a missing local topic as TOPIC_NOT_EXIST
- [Bug] CommitLog returns PUT_OK for a message that could not be appended, so a failed send is acknowledged as success
- [Bug] The static-topic commands ignore -mf/--mapFile and silently recompute the mapping instead
- [Bug] AdminSendMessage maps a FIFO message group to a different queue than the data plane
- [ISSUE #11356] fix(proxy): hash admin message groups with the data plane's queue hash
- [Bug] Client-directed Proxy Admin RPCs never complete in proxy LOCAL mode: the local relay service drops the in-process caller future
- [ISSUE #11358] fix(proxy): bridge the relay outcome to the in-process caller in LOCAL mode
- store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java:215 - compareTo truncates 64-bit offsets and is inconsistent with equality
- [Bug] Proxy Admin ACL evaluates the source IP against the transport peer, ignoring the PROXY protocol client address
- [ISSUE #11362] fix(proxy): evaluate the admin ACL against the client address, not the transport peer
- Docs
- Java not yet supported