rocketmq-client-go

Apache RocketMQ go client

APACHE-2.0 License

Stars
1.2K
Committers
122
View Code on GitHub Visit Website
Ecosystems: Go

Bot releases are visible (Hide)

rocketmq-client-go - v2.1.2 Latest Release

Published by francisoliverlee about 1 year ago

What's Changed

New Contributors

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

rocketmq-client-go - v2.1.2.rc2

Published by francisoliverlee about 1 year ago

What's Changed

New Contributors

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

rocketmq-client-go - rocketmq-client-go-2.1.2-rc1

Published by ShannonDing over 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

rocketmq-client-go - rocketmq-client-go-2.1.1

Published by ShannonDing about 2 years ago

What's Changed

New Contributors

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

rocketmq-client-go - rocketmq-client-go-2.1.1-rc3

Published by ShannonDing about 2 years ago

What's Changed

New Contributors

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

rocketmq-client-go - rocketmq-client-go-2.1.1-rc2

Published by ShannonDing about 3 years ago

What's Changed

New Contributors

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

rocketmq-client-go - rocketmq-client-go-2.1.1-rc1

Published by ShannonDing about 3 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

rocketmq-client-go - rocketmq-client-go-2.1.0

Published by ShannonDing over 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.
rocketmq-client-go - rocketmq-client-go-2.1.0-rc6

Published by ShannonDing over 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.
rocketmq-client-go - rocketmq-client-go-2.1.0-rc5

Published by ShannonDing about 4 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.
rocketmq-client-go - rocketmq-client-go-2.1.0-rc4

Published by ShannonDing over 4 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.

New Feature

  • [ISSUE #457] feat(nameserver): support name server resolver.

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] set default of SendResult.Status and fix panic
rocketmq-client-go - rocketmq-client-go-2.1.0-rc3

Published by ShannonDing over 4 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.

New Feature

  • [ISSUE #457] feat(nameserver): support name server resolver.

Improvement

  • [ISSUE #474] feat(trace): support name server resolver in TraceConfig.

Bug

  • [ISSUE #472] fix(heartbeat): the value of the message mode, type, and the consume flag is wrong in the heartbeat data.
rocketmq-client-go - rocketmq-client-go-2.1.0-rc2

Published by ShannonDing over 4 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.

New Feature

  • [ISSUE #457] feat(nameserver): support name server resolver.

Improvement

  • [ISSUE #474] feat(trace): support name server resolver in TraceConfig.

Bug

  • [ISSUE #472] fix(heartbeat): the value of the message mode, type, and the consume flag is wrong in the heartbeat data.
rocketmq-client-go - rocketmq-client-go-2.1.0-rc1

Published by ShannonDing over 4 years ago

The main goal of this release is to improve stability, usability, and fix bugs.

New Feature

  • [ISSUE #457] feat(nameserver): support name server resolver.

Bug

  • [ISSUE #472] fix(heartbeat): the value of the message mode, type, and the consume flag is wrong in the heartbeat data.
rocketmq-client-go - rocketmq-client-go-2.0.0

Published by ShannonDing over 4 years ago

This is the first product ready RocketMQ Client in pure go, it supports almost the full features of Apache RocketMQ, such as pub and sub messages, ACL, tracing and so on.

New Feature

Improvement

  • [ISSUE #438] Add WithNameServerDomain for producer opt . 

Bug

  • [ISSUE #437] Fix the issue that can not consume the messages in the retry topic .
  • [ISSUE #442] Change consume type to avoid fastjson decode error in lower broker version .
  • [ISSUE #445] UpdateNameServerAddress shoule be called before producer start to avoid to lead to a panic.
  • [ISSUE #449] Correct msgid using unique id .
  • [ISSUE-#450]   Ignore eof error when conn closed.
  • [ISSUE #462] Fix the trace message was send failed.
rocketmq-client-go - rocketmq-client-go-2.0.0-rc2

Published by ShannonDing over 4 years ago

The main goal of this release is to improve stability, usability, and fix bugs. meantime, this release update the package version to v2.

New Feature

  • ISSUE #378 chore(doc): update notice and open statistic label.
  • ISSUE #385 feat(mod): update go mod to support v2.
  • ISSUE #416 feat(producer): auto create topic support in the producer.
  • ISSUE #420 feat(strategy): sort the message queue list with ASC when do rebalance.

Improvement

  • ISSUE #403 refactor(consumer): remove retry topic check when consumer start. 
  • ISSUE #406 refactor(nameserver): refactor the implement of UpdateTopicRouteInfo function.
  • ISSUE #408 feat(buffer): reuse bytes.Buffer in message ID creating.
  • ISSUE #414 fix(consumer): use sync method to upload offset instead async method.

Bug

  • ISSUE #387 fix(consumer): cocorrect the consume type when get runtime info from broker.
  • ISSUE #390 fix(consumer): move updatePullFromWhichNode ahead of result check.
  • ISSUE #393 fix(consumer): should not lock all message queues when push comsumer start.
  • ISSUE #396 fix(core): unalign field panic in the atomic operation .
  • ISSUE #418 fix(consumer): subinfo is updated failed when the message queues are scale out.
  • ISSUE #422 chore(travisci): use archive server to avoid download rocketmq package failed .
  • ISSUE #429 fix(consumer): the brokerName is not found when the broker recover from machine crash.
  • ISSUE #436 fix(producer): update name server address immediately when client start.
rocketmq-client-go - rocketmq-client-go-2.0.0-rc1

Published by wenfengwang almost 5 years ago

The main goal of this release is to improve stability, usability, and fix bugs. meantime, this release supports some new features like namesrv domain, batch message send, panic handler.

New Feature

Improvement

Bug

Document and code style improvement

rocketmq-client-go - rocketmq-client-go-2.0.0-alpha3

Published by wenfengwang almost 5 years ago

The main goal of this release is to improve stability, usability, and fix bugs. meantime, this release supports some new features like delay messages, transaction producer, namespace, etc.

New Feature

Improvement

  • [ISSUE-120]: update defaultConsumer.client init AND add push_consumer testing
  • [ISSUE-128]: update mockgen command line
  • [ISSUE-130]: add Shutdown of PushConsumer
  • [ISSUE-134]: unify interceptor usage
  • [ISSUE-139]: add locker for updating data
  • [ISSUE-148]: add consume/statistic.go unit test
  • [ISSUE-176]: add ctx to rmqClient & remoteClient
  • [ISSUE-178]: add ut for defaultConsumer
  • [ISSUE-180]: add tag filter example.
  • [ISSUE-188]: fix consumer example & remove extra file
  • [ISSUE-190]: modify some code to be more elegant.
  • [ISSUE-192]: refactor MessageSelector
  • [ISSUE-194]: fix: avoid extra err info when pushConsumer startup
  • [ISSUE-195]: fix the domain checker was rollback before
  • [ISSUE-201]: change default consumer option to Clustering
  • [ISSUE-243]: fix: replace consistent package
  • [ISSUE-252]: reduce receive memory usage
  • [ISSUE-259]: graceful shutdown pc locker
  • [ISSUE-304]: use Atomic-Bool

Bug

  • [ISSUE-120]: add broadcast consumer examples
  • [ISSUE-120]: update strategy and add offset_store test
  • [ISSUE-135]: fix bufio.Scanner token too long error
  • [ISSUE-144]: fix nil pointer when file not exist
  • [ISSUE-164]: add UnCompress function implementation
  • [ISSUE-166]: make Access Message.Properties thread safety
  • [ISSUE-173]: fix namesrv rr bug and remove extra code.
  • [ISSUE-183]: add set consumeMessageBatchMaxSize and fixed count++ skip one message
  • [ISSUE-184]: fix errors of using internal codes in the exported snippet
  • [ISSUE-186]: fix offsetSotre
  • [ISSUE-194]: consumerGroup cannot auto create
  • [ISSUE-202]: fix: support acl for trace
  • [ISSUE-211]: fix unmarhsal messageID bug
  • [ISSUE-221]: fix: avoid file not found err when remove old offset file
  • [ISSUE-234]: fix: support multiple consumer&producer
  • [ISSUE-271]: fix bugs that can't consume multiple topics in single consumer
  • [ISSUE-281]: fix SearchOffsetByTimestamp protocol bug
  • [ISSUE-285]: goroutine leak when shutdown
  • [ISSUE-293]: optimize Close of rmqClient
  • [ISSUE-299]: offset store read missing fallthrough for _ReadMemoryThenStore

Document and code style improvement

rocketmq-client-go - rocketmq-client-go-1.2.4

Published by ShannonDing almost 5 years ago

The main goal of this release is to support some new features, e.g. send an orderly message by sharing key and send transaction messages.

Feature

  • [PR-222] - feat(producer): support lite producer to send message by sharding key 
  • [PR-225] - feat(consumer): add set max cachesize api to support simple flow-control 
  • [PR-261] - feat(transaction): add transaction producer message

Improvement

  • [PR-251] - delete useless GroupName and make subscribe method correct

Bug

  • [PR-246] - fix(travis):remove unnecessary script in travis.yml 
  • [PR-248] - fix(golint): fix warnings for golint check
rocketmq-client-go - rocketmq-client-go-1.2.2

Published by ShannonDing about 5 years ago

This release is for the Golang client of Apache RocketMQ. It is based on the kernel of the CPP client and uses cgo to encapsulate the API Implementation of C.
The current version provides the following functions:

  1. support orderly sending of messages by sharding key;
  2. create some simply demos;
  3. deprecate pull consuming model;
Package Rankings
Top 0.88% on Proxy.golang.org
Badges
Extracted from project README
Build Status License Code Scanning Tests CodeCov Go Report Card GoDoc GitHub release Average time to resolve an issue Percentage of issues still open Twitter Follow
Related Projects
rocketmq-clients

RocketMQ Clients - Collection of Client Bindings for Apache RocketMQ

17 Jun 2022 309
golang-developer-roadmap

Roadmap to becoming a Go developer in 2020

15 Apr 2019 17,495
microservices-rabbitmq

Golang Microservices for implementing pub/sub messesing using RabbitMQ.

09 Nov 2022 24
go-api-boilerplate

Go Server/API boilerplate using best practices DDD CQRS ES gRPC

14 Oct 2017 888
amqp

Go client for AMQP 0.9.1

25 Apr 2012 4,861
shop-golang-microservices

Practical microservices based on different software architecture and technologies like Golang, CQ...

08 Aug 2022 265
dubbo-go

Go Implementation For Apache Dubbo .

08 Aug 2018 4,693