rocketmq-client-go
rocketmq-client-go copied to clipboard
apache
Apache RocketMQ go client
**BUG REPORT** 1. Please describe the issue you observed: - consumer send reply message (eg: "This's my answer") with RPC mode. - producer shoud get response message which body is...
**BUG REPORT** 1. Please describe the issue you observed: - What did you do (The steps to reproduce)? - What did you expect to see? Don't panic. - What did...
## What is the purpose of the change i think we should incr instanceCount once, if we Start a consumer more than one times, instanceCount will increase one times, in...
Update readme file according to the new features in the latest release version.
We setup producer with WithQueueSelector, but found some messages with same hashkey was sent to different broker. After insearch of the code, found that the way of sorting queues maybe...
1. Provides more admin APIs, such as createTopicInCluster, createSubscriptionGroup, etc. Currently, only supports two apis: ``` go type Admin interface { CreateTopic(ctx context.Context, opts ...OptionCreate) error DeleteTopic(ctx context.Context, opts ...OptionDelete)...
see https://deps.dev/go/github.com%2Fapache%2Frocketmq-client-go%2Fv2
add some admin tool api 1. FetchAllTopicList 2. GetBrokerClusterInfo 3. FetchPublishMessageQueues
## Due Diligence It is well known that we are attaching great importance to the multi-language clients of the RocketMQ. We have released several versions, and continue to optimize them....
## What is the purpose of the change #845 because https://github.com/apache/rocketmq/pull/4432 change route info to standard json such as: `{"brokerDatas":[{"brokerAddrs":{"0":"127.0.0.1:10911"}]}` the old is: `{"brokerDatas":[{"brokerAddrs":{0:"127.0.0.1:10911"}]}` ## Brief changelog XX ## Verifying...
