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 remoting end transaction ignores async failures Open

apache/rocketmq#10797 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Proxy gRPC HeaderInterceptor fails on unresolved socket addresses Open

apache/rocketmq#10799 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Proxy admin topicExist hides non-not-found route lookup errors Open

apache/rocketmq#10801 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Proxy heartbeat sync logs full subscription data Open

apache/rocketmq#10804 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Proxy remoting expired request cleanup silently swallows exceptions Open

apache/rocketmq#10806 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Proxy delay level parsing should tolerate extra whitespace Open

apache/rocketmq#10808 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Authentication audit logs expose request signatures Open

apache/rocketmq#10810 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Optimize BrokerShutdownTest to complete within the Bazel small timeout Open

apache/rocketmq#10823 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Proxy Admin: standardized gRPC management interface on the Proxy Open

type/enhancement

apache/rocketmq#10825 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
MQVersion throws ArrayIndexOutOfBoundsException for negative version values Open

apache/rocketmq#10829 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
ControllerConfig truncates DLedger peer addresses containing hyphens Open

apache/rocketmq#10830 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Compaction OffsetMap fails when hash index is Integer.MIN_VALUE Open

apache/rocketmq#10831 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
RemotingCommand.decode throws unchecked exceptions for malformed frame headers Open

apache/rocketmq#10832 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Metrics labels and headers discard values containing colons Open

apache/rocketmq#10833 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
RemotingHelper parses bracketed IPv6 broker addresses incorrectly Open

apache/rocketmq#10834 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
TopicConfig.decode mutates state or throws for malformed config Open

apache/rocketmq#10835 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
KeyBuilder strips retry topics for a different consumer group Open

apache/rocketmq#10836 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
TraceDataEncoder fails after a truncated trace record Open

apache/rocketmq#10837 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Malformed orderTopicConf crashes client and proxy route conversion Open

apache/rocketmq#10838 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Static topic mapping may select a stale epoch when the epoch delta overflows Open

apache/rocketmq#10849 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
mqadmin commands misorder large counters and timestamps Open

apache/rocketmq#10850 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Cold data control may skip the group with the highest threshold Open

apache/rocketmq#10851 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Pop revive service may process large revive offsets out of order Open

apache/rocketmq#10852 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Auto-switch HA readers do not handle unknown state ordinals safely Open

apache/rocketmq#10853 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] IndexStoreService reports success after index writes exhaust retries Open

apache/rocketmq#10859 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] OpenMessaging DefaultPromise.get returns before completion Open

apache/rocketmq#10860 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] cleanBrokerMetadata accepts malformed broker controller IDs Open

apache/rocketmq#10861 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Filter parser rejects zero floating-point literals Open

apache/rocketmq#10862 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] CheckpointFile cannot persist empty checkpoints Open

apache/rocketmq#10863 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] ProcessQueue may return a stale next offset for out-of-order messages Open

apache/rocketmq#10870 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] StatisticsBrief accepts invalid percentile metadata Open

apache/rocketmq#10871 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] BrokerData.selectBrokerAddr crashes for an empty address table Open

apache/rocketmq#10873 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] FlatAppendFile readAsync truncates reads spanning more than two segments Open

apache/rocketmq#10878 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Replacing topic metadata preserves a stale update timestamp Open

apache/rocketmq#10879 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Proxy gRPC telemetry maps invalid language metadata to INTERNAL Open

apache/rocketmq#10890 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Topic candidate selection races with concurrent cache eviction Open

apache/rocketmq#10892 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Enforce Lite subscription quota for complete and batch updates Open

apache/rocketmq#10894 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Validate every Lite consumer subscription against its bound topic Open

apache/rocketmq#10895 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Enhancement] NettyEventExecutor shutdown waits for the eventQueue poll timeout because wakeup() cannot release it Open

apache/rocketmq#10898 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Consume TPS and message-out metrics are missing when KV POP is enabled Open

apache/rocketmq#10899 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[studio][Bug] Proxy OTLP header parsing can reject valid values and expose secrets Open

apache/rocketmq#10901 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[studio][Bug] Malformed retry counters can abort Proxy message forwarding Open

apache/rocketmq#10904 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Broker may persist remoting frames from independent connections in a message body Open

apache/rocketmq#10911 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] PopConsumerRocksdbStore leaks RocksDB Slice objects Open

apache/rocketmq#10912 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] gRPC FIFO batch sends ignore the message group when selecting a queue Open

apache/rocketmq#10924 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Cluster transaction service throws before broker address mapping is initialized Open

apache/rocketmq#10931 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Proxy drops receipt handles when offline cleanup renewal fails Open

apache/rocketmq#10933 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Shutting down one producer stops timeout flushing for producers with the same client ID Open

apache/rocketmq#10935 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Enhancement] Avoid temporary full-message buffers during batch encoding Open

apache/rocketmq#10936 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Proxy Remoting forwarding NPEs when bname extFields are absent Open

apache/rocketmq#10939 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026

apache/rocketmq

Get new issues in your inbox