Hello RocketMQ Community, This is the discussion for the RocketMQ-Client-Go 2.1.2 Release. Github repo: https://github.com/apache/rocketmq-client-go/tree/v2.1.2.rc2
The current version updates mainly: 1. Add filter hooks in consumer 2. Add consumer and producer client add unit support (WithUnitName) 3. Add api GetOffsetDiffMap 4. Add param which like consumeThreadMin of java sdk to control consumption rate 5. Add user defined topic dimension consumer limiter 6. Fix goroutine leak 7. Fix query not found 8. Fix consumer doesn't consume message because of blocked on Lock 9. Fix the groupName takes the namespace prefix 10. Fix pq.mutex lock blocked 11. fix: the message may be cleaned when the message has not been consumed 12. Fix: select one message queue of different broker when retry to send 13. fix wrong adding for set when tags are set 14. fix: unsubscribed topic queues not dropped 15. fix Batch send message can't auto create topic 16. fix: topic pubishInfo and subscribeInfo not update more updates to see : https://github.com/apache/rocketmq-client-go/tree/v2.1.2.rc2 The vote will be open for at least 72 hours or until a necessary number of votes are reached. Please vote accordingly: [ ] +1 approve [ ] +0 no opinion [ ] -1 disapprove with the reason Thanks, The Apache RocketMQ Team
