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
- [Bug] Bug title 无法删除 PolicyType为Default 的 acl
- Set the consumer instanceName to "proxy_heartbeat_{port}" instead of default.
- [Enhancement] Enhancement title 实现了一个同时支持多instance的RocketMQ的starter组件,抽象了重复的binder代码
- [Enhancement] Remove synchronized from deleteTopic to speed up topic deletion.
- [Bug] NullPointerException in AdminBrokerProcessor.updateAndCreateTopicList at line 636
- [Bug] Prevent AsyncLearner from being elected as Master during initialization
- [Enhancement] Inconsistent string validation in ProxyConfig.initData() may cause misleading exceptions.
- [ISSUE-3397] Fix checkstyle violations in quickstart examples
- Bump org.assertj:assertj-core from 3.22.0 to 3.27.7
- [Enhancement] Support ChangeInvisibleTime without incrementing message reconsume times
- Docs
- Java not yet supported