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] rocketmq 2m2s集群环境下,客户端使用golang/v5.1.0-rc.1,只能及时消费其中一个broker的消息,另一个broker上的消息不能及时消费 ,有很大的延时
- [ISSUE #8772] Remove lock mq step in broadcasting mode rebalancing
- [bug] rocketmq5.2.0 开启proxy的。local模式的时候,使用proxy的grpc端口发送消息不正常。出现 task was cancelled
- [Bug] Bug title broker进程异常中止
- [Bug] ConsumeQueue minOffset did not update when the corresponding CommitLog files were all deleted
- [ISSUE #8753]ConsumeQueue minOffset did not update when the corresponding CommitLog files were all deleted
- [Enhancement] batch send support compression 批量发送支持压缩
- [Bug] pop.log日志rollingPolicy未开启压缩,导致占用磁盘空间
- [ISSUE #8756] fix broker logback config, gzip the archive files.
- [ISSUE #8755] batch send support compression
- Docs
- Java not yet supported