apache/rocketmq-client-go

Apache RocketMQ go client

Stars: 1.4k
Forks: 445
Open beginner issues: 0
Indexed issues: 86

Dominant language: Go
License: Apache-2.0
Last GitHub push: Jan 12, 2026
Latest indexed: Sep 16, 2026
Contributing guide: Contributing guide
Code of conduct: Code of conduct
Beginner labels: good first issue help wanted
PR merge metrics: No merged PRs in 30d

Open All

86 open issues indexed

issue: the `ctx` not work for consumer.PullFrom method Open

apache/rocketmq-client-go#1131 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
pull mode consume history message very slow Open

apache/rocketmq-client-go#1134 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 16, 2026
push consumer may have concurrency issue for the map which used by control the goroutine numbers Open

apache/rocketmq-client-go#1146 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
goroutine leak when calling rocketmq.NewPushConsumer frequently Open

apache/rocketmq-client-go#1147 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
help, tigger ErrProducerStartFailed Open

apache/rocketmq-client-go#1149 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 16, 2026
How to support fifo messages with messagegroup feature using pushconsumer？ Open

apache/rocketmq-client-go#1151 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
Why was an obviously wrong commit merged? Open

doc good first issue

apache/rocketmq-client-go#1156 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 16, 2026
sendAsync don‘t retry Open

bug

apache/rocketmq-client-go#1157 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
[Feature] Provide a method to get MaxOffset/TopicStatsTable Open

apache/rocketmq-client-go#1167 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
FetchAllTopicList Error Open

apache/rocketmq-client-go#1168 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
[Panic] When the mq server is unavailable, calling the SendAsync interface will panic Open

apache/rocketmq-client-go#1170 · 1 comment · 1 reaction · 0 assignees · Indexed Sep 16, 2026
SendSync Occasionally return topic=xxx route info not found err Open

apache/rocketmq-client-go#1173 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
plase release new version Open

apache/rocketmq-client-go#1177 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 16, 2026
a question about max delay time Open

apache/rocketmq-client-go#1181 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
bug:pullConsumer#seek won't work due to wrong map key type Open

apache/rocketmq-client-go#1183 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
It's recommended to use English comments: // Probably not deserialized back. Open

apache/rocketmq-client-go#1185 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
[BUG] During the update of the NameServer, messages may be sent to the slave Open

apache/rocketmq-client-go#1186 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
Golang接口啥时候支持查看topicstatus啊 Open

apache/rocketmq-client-go#1188 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 16, 2026
produce send timeout is 3s in release 2.1.2 Open

apache/rocketmq-client-go#1190 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
[BUG] GO SDK 可能因为消息的 properties 中包含超过 utf-8 字符集范围的特殊字符导致发送消息时 acl 校验失败 Open

apache/rocketmq-client-go#1192 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
feat request: support consumergroup management in admin interface Open

apache/rocketmq-client-go#1193 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
如何平滑过渡迁移到rocketmq5.x？ Open

apache/rocketmq-client-go#1197 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
[BUG] WriteToFile fails to create backup file before overwriting existing content Open

apache/rocketmq-client-go#1200 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 16, 2026
How to get MaxOffset Open

apache/rocketmq-client-go#1202 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
Go SKD 发送消息推送到从节点 Open

apache/rocketmq-client-go#1204 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 16, 2026
[Feature] Create a topic using clusterName Open

apache/rocketmq-client-go#1209 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 16, 2026
failed to dial tcp when the broker addr is ipv6 Open

apache/rocketmq-client-go#1215 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 16, 2026
send message failed: CODE: 2, DESC: system busy, start flow control for a while Open

apache/rocketmq-client-go#1218 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
When the consumer is closed, the printed log is exquisite Open

apache/rocketmq-client-go#1223 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
Why does the RocketMQ Java client SDK let transaction producers and normal producers share the same defaultMQProducerImpl for sending messages, while the Go SDK requires creating two separate defaultMQProducerImpl instances? Open

apache/rocketmq-client-go#1224 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 16, 2026
什么时候发布新版本？ Open

apache/rocketmq-client-go#1228 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
Enhance the ConsumeResult code handling in oderly mode Open

apache/rocketmq-client-go#1229 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
最新的SDK在这 👉github.com/apache/rocketmq-clients/tree/master/golang👈 This is the latest sdk Open

apache/rocketmq-client-go#1235 · 1 comment · 1 reaction · 0 assignees · Indexed Sep 16, 2026
[Feature] admin.Admin has no broker ACL management (grant/revoke/list) API Open

apache/rocketmq-client-go#1238 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 16, 2026
[Bug] Orderly consumption per-queue lock is ineffective: QueueLock.fetchLock value receiver copies the sync.Map and returns a new mutex every call Open

apache/rocketmq-client-go#1239 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026
[Bug] statsItem.samplingInHour trims the wrong list, so csListDay grows without bound and day-level stats use an ever-growing window Open

apache/rocketmq-client-go#1241 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 16, 2026

A short digest of beginner-friendly GitHub issues.