Skip to content

rocketmq-client-go-2.1.0-rc6

Pre-release
Pre-release
Compare
Choose a tag to compare
@ShannonDing ShannonDing released this 17 Mar 12:13
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.

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.