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
• @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
• @180909 made their first contribution in #704
• @yuz10 made their first contribution in #709
• @guyinyou made their first contribution in #714
• @MaOreoreorui made their first contribution in #743
• @victory460 made their first contribution in #753
• @yuanmoon made their first contribution in #756
• @WJL3333 made their first contribution in #765
• @hnlq715 made their first contribution in #775
• @chaiyx made their first contribution in #779
• @trxo made their first contribution in #679
• @georgehao made their first contribution in #803
• @aaronwang95 made their first contribution in #833
• @yusank made their first contribution in #841
• @CoderPoet made their first contribution in #773
• @NeonToo made their first contribution in #852
• @weedge made their first contribution in #857
• @icey129 made their first contribution in #820
• @ixzk made their first contribution in #783
• @domyway made their first contribution in #837
• @wang1309 made their first contribution in #834
• @j2gg0s made their first contribution in #851
• @hjxp made their first contribution in #814
• @hYuang made their first contribution in #854
• @LaurenceLiZhixin made their first contribution in #867

Full Changelog: v2.1.0...v2.1.1