v2.1.2

What's Changed

• [ISSUE #876] Safely checking context in trace producer. by @aireet in #863
• [ISSUE #878] Clean expired message in CLUSTERING model for push_consumer by @cserwen in #879
• [ISSUE #882] keep queryTopicRouteInfoFromServer timeout the same as Java by @twz915 in #880
• [ISSUE #884]fix goroutine leak by @lampnick in #885
• Add param which like consumeThreadMin of java sdk to control consumption rate by @cserwen in #883
• [feat] fix query not found by @aireet in #886
• feat: support lite pull consumer by @lampnick in #881
• [ISSUE #862]Update readme file according to the new features in the latest release version. by @ShannonDing in #893
• ISSUE #894: add filter hooks in consumer. by @superhx in #891
• [ISSUE #897] fix consumer doesn't consume message because of blocked on Lock by @wangzeping722 in #898
• (feat): add user defined topic dimension consumer limiter by @superhx in #895
• [ISSUE #845] support standard json by @yuz10 in #846
• [ISSUE #899]Fix the groupName takes the namespace prefix by @zhangjidi2016 in #900
• [ISSUE #901]Close the traceDispatcher when producer or consumer is shutdown by @zhangjidi2016 in #902
• [ISSUE #907]remove useless stats log (#907) by @lampnick in #908
• [ISSUE #904] fix:pq.mutex lock blocked. by @lampnick in #903
• when queue dropped,should'not consume the process queue.(#905) by @lampnick in #906
• [ISSUE #909] Fix consumer stopped consuming when panic in consumeListener by @cserwen in #910
• [ISSUE #912] Update introduction.md by @Oliverwqcwrw in #913
• [ISSUE #922]close file after it was read in internal fiel utils. by @zc24 in #925
• [ISSUE #926] don't share limit channel in pushConsumer by @aireet in #923
• [ISSUE #929] Correct struct comment by @Oliverwqcwrw in #930
• [ISSUE #945]init crCh after topic with namespace to avoid consumption blocked. by @NeonToo in #944
• [ISSUE #939]Pull or poll message support message trace by @zhangjidi2016 in #940
• [ISSUE #935]fix consumer option validate by @0daypwn in #936
• [feat] incr instanceCount in once and fmt codes by @aireet in #888
• [ISSUE #942]correct name typo by @0daypwn in #943
• fix some spell mistakes by @weavernet in #949
• Fix response ResQueryNotFound typo by @jackedelic in #948
• [ISSUE #931] fix filter message by @0daypwn in #932
• [ISSUE #927] fix processQueue remove offset by @0daypwn in #928
• [ISSUE #953] fix limiter with goroutine cover by @maqingxiang in #952
• [ISSUE #956]fix reset offset remove pq by @0daypwn in #957
• push consumer enable getting offset diff map by @NeonToo in #964
• add api GetOffsetDiffMap by @NeonToo in #965
• [ISSUE #961] Fix: data race when update subversion for consumer by @cserwen in #962
• [ISSUE #975]when close consumer, return directly by @wenxuwan in #974
• [ISSUE #986]Reduce the log level when fetch offset success and remove unnecessary mq by @humkum in #987
• [ISSUE #970]fix:logic error when reset retry message's origin topic by @humkum in #971
• [ISSUE #996] invoke user callback and return error info when async process send resp error by @ferrirW in #997
• fix: client version mismatch by @qshuai in #1009
• [ISSUE #999]support admin topicList and groupList method by @Slideee in #1000
• [ISSUE #1002] fix: add log when send heartbeat failed by @cserwen in #1003
• [ISSUE #994] Fix: unlock all queues when consumer shutdown in orderly model by @cserwen in #1015
• Replacing github.com/satori/go.uuid with github.com/google/uuid by @BLAZZ in #972
• fix Panic when close traceDispatcher by @wenxuwan in #1027
• [ISSUE #989] consumer and producer client add unit support (WithUnitName) by @twz915 in #988
• Update README.md by @HubQin in #1026
• [ISSUE #1024] fix: unsubscribed topic queues not dropped by @wgdzlh in #1025
• [ISSUE #1034] fix: the message may be cleaned when the message has not been consumed. by @humkum in #1035
• fix "Batch send message can't auto create topic" by @francisoliverlee in #1040
• [ISSUE #1030] Avoid to append unexpected separator to message key by @gaofeihang in #1031
• empty subcribed topic is allowed to start by @NeonToo in #969
• fix wrong add for set when tags are set by @cserwen in #1001
• [ISSUE #1018] Fix unintended shutdown of shared rmqClient by @wgdzlh in #1019
• support RequestCode GET_CONSUMER_STATUS_FROM_CLIENT by @NeonToo in #985
• change ConsumeGoroutineNums max value allowed by @twz915 in #1049
• DomainWithUnit support existed query parameters by @twz915 in #1061
• [ISSUE #1056] fix: When the consumer and producer have the same topic, the consumer fails to update the topic. by @lvxiao1 in #1059
• [ISSUE #1013] Fix: select one message queue of different broker when retry to send by @cserwen in #1014
• run RebalanceImmediately with goroutine by @wenxuwan in #1081
• fix: topic pubishInfo and subscribeInfo not update by @redlsz in #1084

New Contributors

• @aireet made their first contribution in #863
• @wangzeping722 made their first contribution in #898
• @zhangjidi2016 made their first contribution in #900
• @Oliverwqcwrw made their first contribution in #913
• @zc24 made their first contribution in #925
• @0daypwn made their first contribution in #936
• @weavernet made their first contribution in #949
• @jackedelic made their first contribution in #948
• @maqingxiang made their first contribution in #952
• @humkum made their first contribution in #987
• @ferrirW made their first contribution in #997
• @qshuai made their first contribution in #1009
• @Slideee made their first contribution in #1000
• @BLAZZ made their first contribution in #972
• @HubQin made their first contribution in #1026
• @wgdzlh made their first contribution in #1025
• @francisoliverlee made their first contribution in #1040
• @gaofeihang made their first contribution in #1031
• @lvxiao1 made their first contribution in #1059
• @redlsz made their first contribution in #1084

Full Changelog: https://github.com/...

v2.1.2.rc2

What's Changed

• [ISSUE #1024] fix: unsubscribed topic queues not dropped by @wgdzlh in #1025
• [ISSUE #1034] fix: the message may be cleaned when the message has not been consumed. by @humkum in #1035
• fix "Batch send message can't auto create topic" by @francisoliverlee in #1040
• [ISSUE #1030] Avoid to append unexpected separator to message key by @gaofeihang in #1031
• empty subcribed topic is allowed to start by @NeonToo in #969
• fix wrong add for set when tags are set by @cserwen in #1001
• [ISSUE #1018] Fix unintended shutdown of shared rmqClient by @wgdzlh in #1019
• support RequestCode GET_CONSUMER_STATUS_FROM_CLIENT by @NeonToo in #985
• change ConsumeGoroutineNums max value allowed by @twz915 in #1049
• DomainWithUnit support existed query parameters by @twz915 in #1061
• [ISSUE #1056] fix: When the consumer and producer have the same topic, the consumer fails to update the topic. by @lvxiao1 in #1059
• [ISSUE #1013] Fix: select one message queue of different broker when retry to send by @cserwen in #1014
• run RebalanceImmediately with goroutine by @wenxuwan in #1081
• fix: topic pubishInfo and subscribeInfo not update by @redlsz in #1084

New Contributors

• @wgdzlh made their first contribution in #1025
• @francisoliverlee made their first contribution in #1040
• @gaofeihang made their first contribution in #1031
• @lvxiao1 made their first contribution in #1059
• @redlsz made their first contribution in #1084

Full Changelog: v2.1.2.rc1...v2.1.2.rc2

rocketmq-client-go-2.1.2-rc1

What's Changed

• [ISSUE #876] Safely checking context in trace producer. by @aireet in #863
• [ISSUE #878] Clean expired message in CLUSTERING model for push_consumer by @cserwen in #879
• [ISSUE #882] keep queryTopicRouteInfoFromServer timeout the same as Java by @twz915 in #880
• [ISSUE #884]fix goroutine leak by @lampnick in #885
• Add param which like consumeThreadMin of java sdk to control consumption rate by @cserwen in #883
• [feat] fix query not found by @aireet in #886
• feat: support lite pull consumer by @lampnick in #881
• [ISSUE #862]Update readme file according to the new features in the latest release version. by @ShannonDing in #893
• ISSUE #894: add filter hooks in consumer. by @superhx in #891
• [ISSUE #897] fix consumer doesn't consume message because of blocked on Lock by @wangzeping722 in #898
• (feat): add user defined topic dimension consumer limiter by @superhx in #895
• [ISSUE #845] support standard json by @yuz10 in #846
• [ISSUE #899]Fix the groupName takes the namespace prefix by @zhangjidi2016 in #900
• [ISSUE #901]Close the traceDispatcher when producer or consumer is shutdown by @zhangjidi2016 in #902
• [ISSUE #907]remove useless stats log (#907) by @lampnick in #908
• [ISSUE #904] fix:pq.mutex lock blocked. by @lampnick in #903
• when queue dropped,should'not consume the process queue.(#905) by @lampnick in #906
• [ISSUE #909] Fix consumer stopped consuming when panic in consumeListener by @cserwen in #910
• [ISSUE #912] Update introduction.md by @Oliverwqcwrw in #913
• [ISSUE #922]close file after it was read in internal fiel utils. by @zc24 in #925
• [ISSUE #926] don't share limit channel in pushConsumer by @aireet in #923
• [ISSUE #929] Correct struct comment by @Oliverwqcwrw in #930
• [ISSUE #945]init crCh after topic with namespace to avoid consumption blocked. by @NeonToo in #944
• [ISSUE #939]Pull or poll message support message trace by @zhangjidi2016 in #940
• [ISSUE #935]fix consumer option validate by @0daypwn in #936
• [feat] incr instanceCount in once and fmt codes by @aireet in #888
• [ISSUE #942]correct name typo by @0daypwn in #943
• fix some spell mistakes by @weavernet in #949
• Fix response ResQueryNotFound typo by @jackedelic in #948
• [ISSUE #931] fix filter message by @0daypwn in #932
• [ISSUE #927] fix processQueue remove offset by @0daypwn in #928
• [ISSUE #953] fix limiter with goroutine cover by @maqingxiang in #952
• [ISSUE #956]fix reset offset remove pq by @0daypwn in #957
• push consumer enable getting offset diff map by @NeonToo in #964
• add api GetOffsetDiffMap by @NeonToo in #965
• [ISSUE #961] Fix: data race when update subversion for consumer by @cserwen in #962
• [ISSUE #975]when close consumer, return directly by @wenxuwan in #974
• [ISSUE #986]Reduce the log level when fetch offset success and remove unnecessary mq by @humkum in #987
• [ISSUE #970]fix:logic error when reset retry message's origin topic by @humkum in #971
• [ISSUE #996] invoke user callback and return error info when async process send resp error by @ferrirW in #997
• fix: client version mismatch by @qshuai in #1009
• [ISSUE #999]support admin topicList and groupList method by @Slideee in #1000
• [ISSUE #1002] fix: add log when send heartbeat failed by @cserwen in #1003
• [ISSUE #994] Fix: unlock all queues when consumer shutdown in orderly model by @cserwen in #1015
• Replacing github.com/satori/go.uuid with github.com/google/uuid by @BLAZZ in #972
• fix Panic when close traceDispatcher by @wenxuwan in #1027
• [ISSUE #989] consumer and producer client add unit support (WithUnitName) by @twz915 in #988
• Update README.md by @HubQin in #1026

New Contributors

• @aireet made their first contribution in #863
• @wangzeping722 made their first contribution in #898
• @zhangjidi2016 made their first contribution in #900
• @Oliverwqcwrw made their first contribution in #913
• @zc24 made their first contribution in #925
• @0daypwn made their first contribution in #936
• @weavernet made their first contribution in #949
• @jackedelic made their first contribution in #948
• @maqingxiang made their first contribution in #952
• @wenxuwan made their first contribution in #974
• @humkum made their first contribution in #987
• @ferrirW made their first contribution in #997
• @qshuai made their first contribution in #1009
• @Slideee made their first contribution in #1000
• @BLAZZ made their first contribution in #972
• @HubQin made their first contribution in #1026

Full Changelog: v2.1.1...v2.1.2.rc1

rocketmq-client-go-2.1.1

What's Changed

• [ISSUE #644] Fix the zlibWriterPools doesn't work leads to high memory usage by @cserwen in #645
• [ISSUE #640]fix PullInterval unit. by @twz915 in #639
• fix: fix crash on selecting queue. by @NAND86 in #643
• [ISSUE #635] Improving decoding performance for remoting commands by @czah in #636
• [ISSUE #662] Fix the usage bug of namespace by @Git-Yang in #665
• [ISSUE #651] fix an issue where a map read operation was not protected by the lock by @czah in #652
• [ISSUE #678] optimizing goroutine of Stat creation by @wenfengwang in #677
• (fix): wrap topic with namespace when unsubscribe by @superhx in #680
• [ISSUE #585] Fix the wrong StoreHost and GroupName with consume trace message by @maixiaohai in #586
• [ISSUE #614] Fix go routine leaks when consumer close with msg channel blocked by @maixiaohai in #642
• [ISSUE #694] Fix typos. by @wayilau in #689
• [ISSEU 683]request parameter type error fix by @Git-Yang in #684
• [ISSUE #695] Feat: support IPV6 by @Allenxuxu in #641
• [ISSUE #631] Support Consuming from Slave by @maixiaohai in #632
• [ISSUE #688] fix: type assert panic by @fengberlin in #697
• [ISSUE #698] fix: call cancel() as soon as possible to release the resources associatd with context by @fengberlin in #691
• [ISSUE #637] Fix filter lookback interface for utils.ClientIP by @kallydev in #700
• [ISSUE #659] make consumeMessageBatchMaxSize default value consistent with java client by @maixiaohai in #660
• [ISSUE #701] Fix timeout of SendAsync by @Imfan in #702
• fix: add missing log level fatal by @180909 in #704
• [ISSUE #681]feat(internal): support reset consumer offset by @maixiaohai in #682
• [ISSUE #710] Fix send duplicate message in trace interceptor by @yuz10 in #709
• [ISSUE #595] Update go.mod by @wenfengwang in #706
• [ISSUE #699] Fix the bug caused by master broker node is down by @guyinyou in #714
• (fix): fix push_consumer#unsubscribe unsubscribe retry by @superhx in #712
• [ISSUE #716] Fix the bug caused in HA cluster in pull_consumer by @guyinyou in #717
• (fix): set subversion when buildSubscriptionData by @superhx in #720
• [ISSUE #722] fix the bug caused by failover in consumer by @guyinyou in #723
• [ISSUE #735] centralized management errors by @180909 in #708
• [ISSUE #731] Optimize the update offset logic by @Git-Yang in #732
• [ISSUE #650] fix: correctly mark messages to be reconsumed by @luyui in #693
• [ISSUE #744] check multiple topics in one batch by @MaOreoreorui in #743
• [ISSUE #752] change argument to pointer-like to avoid allocations by @victory460 in #753
• [ISSUE #757] Fix GetHeader type conflict by @Git-Yang in #758
• [ISSUE #726] feat: replace fmt to rlog by @yuanmoon in #756
• [ISSUE #759] Change ResetOffsetBody response parse method to support fastjson schema by @WJL3333 in #765
• fix: update gjson for security problem by @hnlq715 in #775
• [issue #778] Build instance name with nanosecond by @chaiyx in #779
• Refactor the client instance struct，converge the namesrv module by @guyinyou in #788
• [ISSUE #806] Fix the feature that GetNamesrv by @guyinyou in #805
• [ISSUE #807] fix code style by @Git-Yang in #808
• fix long time block when remote endpoint crash. by @WJL3333 in #816
• [ISSUE #818] fix msg.Body compressed cause error in transaction message processing by @trxo in #679
• fix queueMaxSpanFlowControlTimes not change by @cserwen in #824
• [ISSUE #828] Support rlog rotate by @WJL3333 in #829
• [ISSUE #827] Support get consumerRunningInfo return goroutine stack by @WJL3333 in #826
• fix some params for consumer can not be changed by @cserwen in #825
• [ISSUE #810] fix async producer example by @yuz10 in #809
• Feat/rpc request by @georgehao in #803
• [ISSUE #832] Client may submit wrong offset when network instability by @aaronwang95 in #833
• [ISSUE #823]fix: panic problem caused by json-iterator in go1.18 by @yusank in #841
• fix(sendOneWay): fix stack overflow caused by recursive calls by @CoderPoet in #773
• bugfix rebalance is not paused after suspend and rebalance not trigge… by @NeonToo in #852
• feat: exchange messages_utils dir by @georgehao in #858
• fix: selectMessageQueue nil *internal.TopicPublishInfo by @weedge in #857
• [ISSUE #774] Avoid cancel context too early cause trace data fail. by @WJL3333 in #856
• [ISSUE #628]takeMessages sleep max 5s by @qianlongzt in #629
• [ISSUE #819] Fix sis.samplingInSeconds and sis.printAtMinutes() running in different goroutines cause DATA RACE by @icey129 in #820
• Maybe can remove some useless code in encodeBatch() by @ixzk in #783
• [ISSUE #847] fix primitive.WithMethod ctx transfer by @domyway in #837
• [ISSUE #840]consumer consume include tag according to accumulation by @wang1309 in #834
• [ISSUE #813] Fix bug when get mqadmin consumerStatus can't get consume status. by @WJL3333 in #812
• feat(fmt): compare slice length directly by @j2gg0s in #851
• fix pullThresholdSizeForTopic invalid by @hjxp in #814
• add some methods for pushConsumer by @cserwen in #849
• [ISSUE #843] fix request offset will not be changed in some case by @cserwen in #844
• a liitle improvement use chan instead by @hYuang in #854
• [ISSUE #797] Fix msg lost if consumer crash when send msg back failed. by @ShannonDing in #860
• [ISSUE #754] close msgCh when pq droped by @ShannonDing in #859
• [ISSUE #780]avoid sendmessage back with origin message body in request. by @WJL3333 in #865
• [ISSUE #728] client shutdown abnormally by @Git-Yang in #729
• [ISSUE #864] update rlog to 1.9.0 to fix CVE-2022-29526 in golang.org/x/sys by @ShannonDing in #868
• [ISSUE #869] Fix: Consumer api comments by @LaurenceLiZhixin in #867
• [ISSUE #790] use uber atomic lib to avoid atomic value data race. by @WJL3333 in #866
• [ISSUE #870] add license header for some new files. by @ShannonDing in #871
• [ISSUE #872] fix code coverage shell error in travis ci yml. by @ShannonDing in #873

New Contributors

• @cserwen made their first contribution in #645
• @czah made their first contribution in #636
• @Git-Yang made their first contribution in #665
• @sup...

rocketmq-client-go-2.1.1-rc3

What's Changed

• [ISSUE #644] Fix the zlibWriterPools doesn't work leads to high memory usage by @cserwen in #645
• [ISSUE #640]fix PullInterval unit. by @twz915 in #639
• fix: fix crash on selecting queue. by @NAND86 in #643
• [ISSUE #635] Improving decoding performance for remoting commands by @czah in #636
• [ISSUE #662] Fix the usage bug of namespace by @Git-Yang in #665
• [ISSUE #651] fix an issue where a map read operation was not protected by the lock by @czah in #652
• [ISSUE #678] optimizing goroutine of Stat creation by @wenfengwang in #677
• (fix): wrap topic with namespace when unsubscribe by @superhx in #680
• [ISSUE #585] Fix the wrong StoreHost and GroupName with consume trace message by @maixiaohai in #586
• [ISSUE #614] Fix go routine leaks when consumer close with msg channel blocked by @maixiaohai in #642
• [ISSUE #694] Fix typos. by @wayilau in #689
• [ISSEU 683]request parameter type error fix by @Git-Yang in #684
• [ISSUE #695] Feat: support IPV6 by @Allenxuxu in #641
• [ISSUE #631] Support Consuming from Slave by @maixiaohai in #632
• [ISSUE #688] fix: type assert panic by @fengberlin in #697
• [ISSUE #698] fix: call cancel() as soon as possible to release the resources associatd with context by @fengberlin in #691
• [ISSUE #637] Fix filter lookback interface for utils.ClientIP by @kallydev in #700
• [ISSUE #659] make consumeMessageBatchMaxSize default value consistent with java client by @maixiaohai in #660
• [ISSUE #701] Fix timeout of SendAsync by @Imfan in #702
• fix: add missing log level fatal by @180909 in #704
• [ISSUE #681]feat(internal): support reset consumer offset by @maixiaohai in #682
• [ISSUE #710] Fix send duplicate message in trace interceptor by @yuz10 in #709
• [ISSUE #595] Update go.mod by @wenfengwang in #706
• [ISSUE #699] Fix the bug caused by master broker node is down by @guyinyou in #714
• (fix): fix push_consumer#unsubscribe unsubscribe retry by @superhx in #712
• [ISSUE #716] Fix the bug caused in HA cluster in pull_consumer by @guyinyou in #717
• (fix): set subversion when buildSubscriptionData by @superhx in #720
• [ISSUE #722] fix the bug caused by failover in consumer by @guyinyou in #723
• [ISSUE #735] centralized management errors by @180909 in #708
• [ISSUE #731] Optimize the update offset logic by @Git-Yang in #732
• [ISSUE #650] fix: correctly mark messages to be reconsumed by @luyui in #693
• [ISSUE #744] check multiple topics in one batch by @MaOreoreorui in #743
• [ISSUE #752] change argument to pointer-like to avoid allocations by @victory460 in #753
• [ISSUE #757] Fix GetHeader type conflict by @Git-Yang in #758
• [ISSUE #726] feat: replace fmt to rlog by @yuanmoon in #756
• [ISSUE #759] Change ResetOffsetBody response parse method to support fastjson schema by @WJL3333 in #765
• fix: update gjson for security problem by @hnlq715 in #775
• [issue #778] Build instance name with nanosecond by @chaiyx in #779
• Refactor the client instance struct，converge the namesrv module by @guyinyou in #788
• [ISSUE #806] Fix the feature that GetNamesrv by @guyinyou in #805
• [ISSUE #807] fix code style by @Git-Yang in #808
• fix long time block when remote endpoint crash. by @WJL3333 in #816
• [ISSUE #818] fix msg.Body compressed cause error in transaction message processing by @trxo in #679
• fix queueMaxSpanFlowControlTimes not change by @cserwen in #824
• [ISSUE #828] Support rlog rotate by @WJL3333 in #829
• [ISSUE #827] Support get consumerRunningInfo return goroutine stack by @WJL3333 in #826
• fix some params for consumer can not be changed by @cserwen in #825
• [ISSUE #810] fix async producer example by @yuz10 in #809
• Feat/rpc request by @georgehao in #803
• [ISSUE #832] Client may submit wrong offset when network instability by @aaronwang95 in #833
• [ISSUE #823]fix: panic problem caused by json-iterator in go1.18 by @yusank in #841
• fix(sendOneWay): fix stack overflow caused by recursive calls by @CoderPoet in #773
• bugfix rebalance is not paused after suspend and rebalance not trigge… by @NeonToo in #852
• feat: exchange messages_utils dir by @georgehao in #858
• fix: selectMessageQueue nil *internal.TopicPublishInfo by @weedge in #857
• [ISSUE #774] Avoid cancel context too early cause trace data fail. by @WJL3333 in #856
• [ISSUE #628]takeMessages sleep max 5s by @qianlongzt in #629
• [ISSUE #819] Fix sis.samplingInSeconds and sis.printAtMinutes() running in different goroutines cause DATA RACE by @icey129 in #820
• Maybe can remove some useless code in encodeBatch() by @ixzk in #783
• [ISSUE #847] fix primitive.WithMethod ctx transfer by @domyway in #837
• [ISSUE #840]consumer consume include tag according to accumulation by @wang1309 in #834
• [ISSUE #813] Fix bug when get mqadmin consumerStatus can't get consume status. by @WJL3333 in #812
• feat(fmt): compare slice length directly by @j2gg0s in #851
• fix pullThresholdSizeForTopic invalid by @hjxp in #814
• add some methods for pushConsumer by @cserwen in #849
• [ISSUE #843] fix request offset will not be changed in some case by @cserwen in #844
• a liitle improvement use chan instead by @hYuang in #854
• [ISSUE #797] Fix msg lost if consumer crash when send msg back failed. by @ShannonDing in #860
• [ISSUE #754] close msgCh when pq droped by @ShannonDing in #859
• [ISSUE #780]avoid sendmessage back with origin message body in request. by @WJL3333 in #865
• [ISSUE #728] client shutdown abnormally by @Git-Yang in #729
• [ISSUE #864] update rlog to 1.9.0 to fix CVE-2022-29526 in golang.org/x/sys by @ShannonDing in #868
• [ISSUE #869] Fix: Consumer api comments by @LaurenceLiZhixin in #867
• [ISSUE #790] use uber atomic lib to avoid atomic value data race. by @WJL3333 in #866
• [ISSUE #870] add license header for some new files. by @ShannonDing in #871
• [ISSUE #872] fix code coverage shell error in travis ci yml. by @ShannonDing in #873

New Contributors

• @cserwen made their first contribution in #645
• @czah made their first contribution in #636
• @Git-Yang made their first contribution in #665
• @sup...

rocketmq-client-go-2.1.1-rc2

What's Changed

• [ISSUE #644] Fix the zlibWriterPools doesn't work leads to high memory usage by @cserwen in #645
• [ISSUE #640]fix PullInterval unit. by @twz915 in #639
• fix: fix crash on selecting queue. by @NAND86 in #643
• [ISSUE #635] Improving decoding performance for remoting commands by @czah in #636
• [ISSUE #662] Fix the usage bug of namespace by @Git-Yang in #665
• [ISSUE #651] fix an issue where a map read operation was not protected by the lock by @czah in #652
• [ISSUE #678] optimizing goroutine of Stat creation by @wenfengwang in #677
• (fix): wrap topic with namespace when unsubscribe by @superhx in #680
• [ISSUE #585] Fix the wrong StoreHost and GroupName with consume trace message by @maixiaohai in #586
• [ISSUE #614] Fix go routine leaks when consumer close with msg channel blocked by @maixiaohai in #642
• [ISSUE #694] Fix typos. by @wayilau in #689
• [ISSEU 683]request parameter type error fix by @Git-Yang in #684
• [ISSUE #695] Feat: support IPV6 by @Allenxuxu in #641
• [ISSUE #631] Support Consuming from Slave by @maixiaohai in #632
• [ISSUE #688] fix: type assert panic by @fengberlin in #697
• [ISSUE #698] fix: call cancel() as soon as possible to release the resources associatd with context by @fengberlin in #691
• [ISSUE #637] Fix filter lookback interface for utils.ClientIP by @kallydev in #700
• [ISSUE #659] make consumeMessageBatchMaxSize default value consistent with java client by @maixiaohai in #660
• [ISSUE #701] Fix timeout of SendAsync by @Imfan in #702
• fix: add missing log level fatal by @180909 in #704
• [ISSUE #681]feat(internal): support reset consumer offset by @maixiaohai in #682
• [ISSUE #710] Fix send duplicate message in trace interceptor by @yuz10 in #709
• [ISSUE #595] Update go.mod by @wenfengwang in #706
• [ISSUE #699] Fix the bug caused by master broker node is down by @guyinyou in #714
• (fix): fix push_consumer#unsubscribe unsubscribe retry by @superhx in #712
• [ISSUE #716] Fix the bug caused in HA cluster in pull_consumer by @guyinyou in #717
• (fix): set subversion when buildSubscriptionData by @superhx in #720
• [ISSUE #722] fix the bug caused by failover in consumer by @guyinyou in #723

New Contributors

• @czah made their first contribution in #636
• @superhx made their first contribution in #680
• @Allenxuxu made their first contribution in #641
• @fengberlin made their first contribution in #697
• @kallydev made their first contribution in #700
• @Imfan made their first contribution in #702

Full Changelog: v2.1.0...v2.1.1-rc2

rocketmq-client-go-2.1.1-rc1

Prepare to release v2.1.1

What's Changed

• [ISSUE #644] Fix the zlibWriterPools doesn't work leads to high memory usage by @cserwen in #645
• [ISSUE #640]fix PullInterval unit. by @twz915 in #639
• fix: fix crash on selecting queue. by @NAND86 in #643
• [ISSUE #635] Improving decoding performance for remoting commands by @czah in #636
• [ISSUE #662] Fix the usage bug of namespace by @Git-Yang in #665
• [ISSUE #651] fix an issue where a map read operation was not protected by the lock by @czah in #652
• [ISSUE #678] optimizing goroutine of Stat creation by @wenfengwang in #677
• (fix): wrap topic with namespace when unsubscribe by @superhx in #680
• [ISSUE #585] Fix the wrong StoreHost and GroupName with consume trace message by @maixiaohai in #586
• [ISSUE #614] Fix go routine leaks when consumer close with msg channel blocked by @maixiaohai in #642
• [ISSUE #694] Fix typos. by @wayilau in #689
• [ISSEU 683]request parameter type error fix by @Git-Yang in #684
• [ISSUE #695] Feat: support IPV6 by @Allenxuxu in #641
• [ISSUE #631] Support Consuming from Slave by @maixiaohai in #632
• [ISSUE #688] fix: type assert panic by @fengberlin in #697
• [ISSUE #698] fix: call cancel() as soon as possible to release the resources associatd with context by @fengberlin in #691
• [ISSUE #637] Fix filter lookback interface for utils.ClientIP by @kallydev in #700
• [ISSUE #659] make consumeMessageBatchMaxSize default value consistent with java client by @maixiaohai in #660
• [ISSUE #701] Fix timeout of SendAsync by @Imfan in #702
• fix: add missing log level fatal by @180909 in #704
• [ISSUE #681]feat(internal): support reset consumer offset by @maixiaohai in #682
• [ISSUE #710] Fix send duplicate message in trace interceptor by @yuz10 in #709
• [ISSUE #595] Update go.mod by @wenfengwang in #706
• [ISSUE #699] Fix the bug caused by master broker node is down by @guyinyou in #714
• (fix): fix push_consumer#unsubscribe unsubscribe retry by @superhx in #712
• [ISSUE #716] Fix the bug caused in HA cluster in pull_consumer by @guyinyou in #717
• (fix): set subversion when buildSubscriptionData by @superhx in #720

New Contributors

• @czah made their first contribution in #636
• @superhx made their first contribution in #680
• @Allenxuxu made their first contribution in #641
• @fengberlin made their first contribution in #697
• @kallydev made their first contribution in #700
• @Imfan made their first contribution in #702

Full Changelog: v2.1.0...v2.1.1-rc1

rocketmq-client-go-2.1.0

The main goal of this release is to improve stability, usability, and fix bugs and the source code of this release is the copy of the master which has merged from the native branch before.

New Feature

• [ISSUE #457] feat(nameserver): support name server resolver.
• [ISSUE #489] feat(log): support log level set and add more log in offset.
• [ISSUE #552] add new dns name server resolver.
• [ISSUE #608] support message compression.
• [ISSUE #622] support consuming message directly.

Improvement

• [ISSUE #474] feat(trace): support name server resolver in TraceConfig.
• [ISSUE #483] fix README.md typo.
• [ISSUE #531] initialize the retry topic offset when using ConsumeFromLastOffst model.
• [ISSUE #535] refactor the remoting mode to avoid goroutine leak.
• [ISSUE #550] refacter the offset tables in the offset store mode.
• [ISSUE #554] modified typo word Resovler to Resolver.
• [ISSUE #560] allow further subscription even after the client starts, to align with Java SDK's behavior.
• [ISSUE #567] show status code when getting name server failed by HTTP resolver.
• [ISSUE #597] fix command register conflict, add consumer and producer logic code
• [ISSUE #600] fix typo in trace off parameter.
• [ISSUE #607] reduce memory copy for on-wire protocol.
• [ISSUE #613] update lastPullTime use atomic.Value.
• [ISSUE #616] putmessage function should check msg in consumingMsgOrderlyTreeMap.
• [ISSUE #626] implement unsubscribe method for push consumer.

Bug

• [ISSUE #472] fix(heartbeat): the value of the message mode, type, and the consume flag is wrong in the heartbeat data.
• [ISSUE #495] fix(producer): set default of SendResult.Status and fix panic bug.
• [ISSUE #504] fix(reconsume): subMsgs should be used instead of msgs in consume goroutine.
• [ISSUE #527] fix(nameserver): panic in nameserver size is changed.
• [ISSUE #538] fix parameter error in the broker address found function.
• [ISSUE #541] fix parse address error when address has prefix “t”.
• [ISSUE #574] fix possible infinite loop after rebalance.
• [ISSUE #588] fix crash on printing logs.
• [ISSUE #612] fix resatrt issue for the same push consumer.
• [ISSUE #620] retrieve transactionid from property first.

rocketmq-client-go-2.1.0-rc6

The main goal of this release is to improve stability, usability, and fix bugs and the source code of this release is the copy of the master which has merged from the native branch before.

Improvement

• [ISSUE #531] initialize the retry topic offset when using ConsumeFromLastOffst model.
• [ISSUE #535] refactor the remoting mode to avoid goroutine leak.
• [ISSUE #538] fix parameter error in the broker address found function.
• [ISSUE #541] fix parse address error when address has prefix "t".
• [ISSUE #550] refacter the offset tables in the offset store mode.
• [ISSUE #552] add new dns name server resolver.
• [ISSUE #554] modified typo word Resovler to Resolver.
• [ISSUE #560] allow further subscription even after the client starts, to align with Java SDK's behavior
• [ISSUE #567] show status code when getting name server failed by HTTP resolver
• [ISSUE #574] fix possible infinite loop after rebalance.
• [ISSUE #578] get message property failed after it is set to go msg struct.
• [ISSUE #588] fix crash on printing logs.
• [ISSUE #597] fix command register conflict, add consumer and producer logic code.
• [ISSUE #600] fix typo in trace off parameter.
• [ISSUE #607] reduce memory copy for on-wire protocol.
• [ISSUE #608] support message compression.
• [ISSUE #612] fix resatrt issue for the same push consumer.
• [ISSUE #613] update lastPullTime use atomic.Value.
• [ISSUE #616] putmessage function should check msg in consumingMsgOrderlyTreeMap.
• [ISSUE #620] retrieve transactionid from property first.
• [ISSUE #622] support consuming message directly.
• [ISSUE #626] Implement unsubscribe method for push consumer.

rocketmq-client-go-2.1.0-rc5

The main goal of this release is to improve stability, usability, and fix bugs and the source code of this release is the copy of the master which has merged from the native branch before.

New Feature

• [ISSUE #457] feat(nameserver): support name server resolver.
• [ISSUE #489] feat(log): support log level set and add more log in offset.

Improvement

• [ISSUE #474] feat(trace): support name server resolver in TraceConfig.
• [ISSUE #483] fix README.md typo.

Bug

• [ISSUE #472] fix(heartbeat): the value of the message mode, type, and the consume flag is wrong in the heartbeat data.
• [ISSUE #495] fix(producer): set default of SendResult.Status and fix panic bug.
• [ISSUE #504] fix(reconsume): subMsgs should be used instead of msgs in consume goroutine.
• [ISSUE #527] fix(nameserver): panic in nameserver size is changed.