Rocketmq Client Go Versions Save

Apache RocketMQ go client

v2.1.2

9 months ago

What's Changed

New Contributors

Full Changelog: https://github.com/apache/rocketmq-client-go/compare/v2.1.1...v2.1.2

v2.1.2.rc2

10 months ago

What's Changed

New Contributors

Full Changelog: https://github.com/apache/rocketmq-client-go/compare/v2.1.2.rc1...v2.1.2.rc2

v2.1.2.rc1

1 year ago

What's Changed

New Contributors

Full Changelog: https://github.com/apache/rocketmq-client-go/compare/v2.1.1...v2.1.2.rc1

v2.1.1

1 year ago

What's Changed

New Contributors

Full Changelog: https://github.com/apache/rocketmq-client-go/compare/v2.1.0...v2.1.1

v2.1.1-rc3

1 year ago

What's Changed

New Contributors

Full Changelog: https://github.com/apache/rocketmq-client-go/compare/v2.1.0...v2.1.1-rc3

v2.1.1-rc2

2 years ago

What's Changed

New Contributors

Full Changelog: https://github.com/apache/rocketmq-client-go/compare/v2.1.0...v2.1.1-rc2

v2.1.1-rc1

2 years ago

Prepare to release v2.1.1

What's Changed

New Contributors

Full Changelog: https://github.com/apache/rocketmq-client-go/compare/v2.1.0...v2.1.1-rc1

v2.1.0

3 years ago

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.

v2.1.0-rc6

3 years ago

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.

v2.1.0-rc5

3 years ago

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

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.