Apache RocketMQ Client Go 2.1.1 发布

Below is a summary of the issues addressed in the version 2.1.1 release of RocketMQ Client Go. For full documentation of the release, a guide to get started, please refer to Quick Start.

Download the 2.1.1 release

• Source: rocketmq-client-go-2.1.1-source-release.tar.gz [PGP] [SHA512]

What’s Changed

• [ISSUE #644] Fix the zlibWriterPools doesn’t work leads to high memory usage.
• [ISSUE #640] fix PullInterval unit.
• [ISSUE #643] fix crash on selecting queue.
• [ISSUE #635] Improving decoding performance for remoting commands.
• [ISSUE #662] Fix the usage bug of namespace.
• [ISSUE #651] fix an issue where a map read operation was not protected by the lock.
• [ISSUE #678] optimizing goroutine of Stat creation.
• [ISSUE #680] wrap topic with namespace when unsubscribe.
• [ISSUE #585] Fix the wrong StoreHost and GroupName with consume trace message.
• [ISSUE #614] Fix go routine leaks when consumer close with msg channel blocked.
• [ISSUE #694] Fix typos.
• [ISSUE #683] request parameter type error fix.
• [ISSUE #695] Feat: support IPV6.
• [ISSUE #631] Support Consuming from Slave.
• [ISSUE #688] fix: type assert panic.
• [ISSUE #698] fix: call cancel() as soon as possible to release the resources associatd with context.
• [ISSUE #637] Fix filter lookback interface for utils.ClientIP.
• [ISSUE #659] make consumeMessageBatchMaxSize default value consistent with java client.
• [ISSUE #701] Fix timeout of SendAsync.
• [ISSUE #704] add missing log level fatal.
• [ISSUE #681] feat(internal): support reset consumer offset.
• [ISSUE #710] Fix send duplicate message in trace interceptor.
• [ISSUE #595] Update go.mod.
• [ISSUE #699] Fix the bug caused by master broker node is down.
• [ISSUE #712] fix push_consumer#unsubscribe unsubscribe retry.
• [ISSUE #716] Fix the bug caused in HA cluster in pull_consumer.
• [ISSUE #720] set subversion when buildSubscriptionData.
• [ISSUE #722] fix the bug caused by failover in consumer.
• [ISSUE #735] centralized management errors.
• [ISSUE #731] Optimize the update offset logic.
• [ISSUE #650] fix: correctly mark messages to be reconsumed.
• [ISSUE #744] check multiple topics in one batch.
• [ISSUE #752] change argument to pointer-like to avoid allocations.
• [ISSUE #757] Fix GetHeader type conflict.
• [ISSUE #726] feat: replace fmt to rlog.
• [ISSUE #759] Change ResetOffsetBody response parse method to support fastjson schema.
• [ISSUE #775] update gjson for security problem.
• [ISSUE #778] Build instance name with nanosecond.
• [ISSUE #788] Refactor the client instance struct，converge the namesrv module.
• [ISSUE #806] Fix the feature that GetNamesrv.
• [ISSUE #807] fix code style.
• [ISSUE #816] fix long time block when remote endpoint crash.
• [ISSUE #818] fix msg.Body compressed cause error in transaction message processing.
• [ISSUE #824] fix queueMaxSpanFlowControlTimes not change.
• [ISSUE #828] Support rlog rotate.
• [ISSUE #827] Support get consumerRunningInfo return goroutine stack.
• [ISSUE #825] fix some params for consumer can not be changed.
• [ISSUE #810] fix async producer example.
• [ISSUE #803] Feat/rpc request.
• [ISSUE #832] Client may submit wrong offset when network instability.
• [ISSUE #823] fix: panic problem caused by json-iterator in go1.18.
• [ISSUE #773] fix(sendOneWay): fix stack overflow caused by recursive calls.
• [ISSUE #852] bugfix rebalance is not paused after suspend and rebalance not trigge.
• [ISSUE #858] feat: exchange messages_utils dir.
• [ISSUE #857] selectMessageQueue nil *internal.TopicPublishInfo.
• [ISSUE #774] Avoid cancel context too early cause trace data fail.
• [ISSUE #628] takeMessages sleep max 5s.
• [ISSUE #819] Fix sis.samplingInSeconds and sis.printAtMinutes() running in different goroutines cause DATA RACE.
• [ISSUE #783] Maybe can remove some useless code in encodeBatch().
• [ISSUE #847] fix primitive.WithMethod ctx transfer.
• [ISSUE #840] consumer consume include tag according to accumulation.
• [ISSUE #813] Fix bug when get mqadmin consumerStatus can’t get consume status.
• [ISSUE #851] compare slice length directly.
• [ISSUE #814] fix pullThresholdSizeForTopic invalid.
• [ISSUE #849] add some methods for pushConsumer.
• [ISSUE #843] fix request offset will not be changed in some case.
• [ISSUE #854] a little improvement use chan instead.
• [ISSUE #797] Fix msg lost if consumer crash when send msg back failed.
• [ISSUE #754] close msgCh when pq dropped.
• [ISSUE #780] avoid sendmessage back with origin message body in request.
• [ISSUE #728] client shutdown abnormally.
• [ISSUE #864] update rlog to 1.9.0 to fix CVE-2022-29526 in golang.org/x/sys.
• [ISSUE #869] Fix: Consumer api comments.
• [ISSUE #790] use uber atomic lib to avoid atomic value data race.
• [ISSUE #870] add license header for some new files.
• [ISSUE #872] fix code coverage shell error in travis ci yml.

转自 Release Notes – Apache RocketMQ Client Go