Skip to content

rocketmq-client-go-2.1.0

Compare
Choose a tag to compare
@ShannonDing ShannonDing released this 17 Mar 13:33
d6e66a2

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

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.