apache/rocketmq

View on GitHub

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.

Stars: 22.6k
Forks: 12k
Open beginner issues: 0
Indexed issues: 291
Avg merge: 3d 1h
Merged PRs (30d): 27

Dominant language: Java
License: Apache-2.0
Last GitHub push: Sep 14, 2026
Latest indexed: Sep 14, 2026
Contributing guide: Contributing guide
Code of conduct: Code of conduct
Beginner labels: good first issue

Open All

288 open issues indexed

[Bug] Proxy drops receipt handles when offline cleanup task submission is rejected Open

apache/rocketmq#10941 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] EscapeBridge fails to decode messages when queue-offset metadata is incomplete Open

apache/rocketmq#10943 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] POP retry response recoding uses the wrong record after a multi-message batch Open

apache/rocketmq#10945 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Enhancement] Converge pop consumer offset in the background so it does not depend on client polling Open

type/enhancement

apache/rocketmq#10949 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Proxy and broker configuration logs may expose sensitive values Open

apache/rocketmq#10950 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] 顺序消费丢失消息一条（生产环境） Open

apache/rocketmq#10955 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Controller] Protect the Controller remoting management endpoint with authentication and authorization Open

apache/rocketmq#10956 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Enhancement] Improve Lite subscription quota validation for remove actions Open

type/enhancement

apache/rocketmq#10962 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
RocketMQ 5.5.0 的事务消息批处理线程陷入忙循环,CPU 10% Open

apache/rocketmq#10966 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Enhancement] Reduce allocation in ExtraInfoUtil POP info parsing and return primitives from numeric getters Open

apache/rocketmq#10973 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Enhancement] Avoid per-message MessageDigest lookup and length-only getBytes allocations on the proxy gRPC path Open

apache/rocketmq#10976 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Enhancement] Add Nullable annotations to nullable Message getters and fix kotlin-stdlib transitive leak Open

type/enhancement

apache/rocketmq#10978 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Enhancement][Discussion] Cache serialized topic route data in NameServer getRouteInfoByTopic Open

apache/rocketmq#10982 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support preemptive cancel commands that supersede queued LiteTopic messages Open

apache/rocketmq#10983 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] POP revive can lose retry after an asynchronous message-read failure Open

apache/rocketmq#10985 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] QUERY_CORRECTION_OFFSET admin query permanently deletes the filtered groups' consumer offsets Open

apache/rocketmq#10987 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Transactional message escape retry uses 2 ^ n (XOR) instead of exponential backoff, including a zero-delay retry Open

apache/rocketmq#10989 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Pop long-polling: retry topic message with null properties throws NPE in the reput thread and stalls broker-wide dispatch Open

apache/rocketmq#10990 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Tiered storage cannot dispatch messages larger than the group commit size Open

apache/rocketmq#10998 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Enhancement] Avoid per-message getBytes() for topic and CRC32 property key on the broker write path Open

apache/rocketmq#11002 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Enhancement] Reduce allocations in hot-path request headers' toString() by replacing Guava MoreObjects.toStringHelper Open

apache/rocketmq#11003 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Send-failure cause is discarded: requestFail() never records f.cause() Open

apache/rocketmq#11010 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] MessageRocksDBStorage accumulates timer-WAL flush tasks after reload Open

apache/rocketmq#11013 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Delay messages are delivered with internal properties leaked into propertiesString (ScheduleMessageService#messageTimeUp) Open

apache/rocketmq#11037 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Consumers registered via heartbeat-v2 withoutSub are never removed by fast channel-close events Open

apache/rocketmq#11039 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Paginated metadata sync silently drops the last topic/subscription group when count is one over a page boundary Open

apache/rocketmq#11041 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Namesrv: a stale expiry/channel-close unregister wipes a broker's fresh re-registration Open

apache/rocketmq#11043 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Controller: a stale channel-close event evicts a re-registered broker and triggers a spurious master election Open

apache/rocketmq#11045 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Timer enqueue retry re-enqueues already-succeeded requests, delivering scheduled messages multiple times Open

apache/rocketmq#11047 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Proxy gRPC batch send returns one receipt for N messages, so SDKs fail the send although the broker stored the batch Open

apache/rocketmq#11049 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Validate topK in Lite group info queries Open

apache/rocketmq#11055 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Deleted LiteTopics remain in lag latency metrics and timestamp TopK Open

apache/rocketmq#11057 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Lite client info queries do not validate subscription ownership Open

apache/rocketmq#11059 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Enhancement] Support suppressing minimal-value metrics to reduce export payload Open

type/enhancement

apache/rocketmq#11078 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Remoting sub-servers do not honor graceful shutdown Open

apache/rocketmq#11151 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] TimelineRollService may repeatedly roll the same timer messages Open

apache/rocketmq#11156 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] TopicValidator rejects V2 retry topic names containing `+` separator introduced by KeyBuilder Open

apache/rocketmq#11158 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Doc] Gradle snippets in the quick-start docs use the removed compile configuration Open

apache/rocketmq#11159 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026

apache/rocketmq

Get new issues in your inbox