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
- #8509 lmq offset sync master to slave
- [Bug] Bug title 当消费者获取消息不存在的属性,服务端处理过程中会有异常,并把消息的消费状态设置为RECONSUME_LATER,无法进入消费逻辑,客户端也感知不到异常
- [Bug] Compensate for the missing file-based CQ during rollback.
- [Doc] Description of the brokerAddrTable property in MQClientInstance
- [Feature] Can JVM parameters be passed in when starting the broker?
- Fix typos
- [Bug] Network jitter encountered while rebalancing results in repeated consumption or errors in pop mode
- [Bug/Typo] Write lock not released in IndexStoreService
- [Enhancement] Add more test coverage for TopicRouteInfoManager
- [ISSUE #8682] Add more test coverage for TopicRouteInfoManager
- Docs
- Java not yet supported