rocketmq-client-go-2.0.0-alpha3

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

• [ISSUE-120]: add AllocateByConsistentHash algorithm and it's test
• [ISSUE-120]: add GetNamesrv round-robin strategy testing
• [ISSUE-122]: add msg delay to send
• [ISSUE-124]: add trace feature
• [ISSUE-137]: add transaction producer
• [ISSUE-147]: support Namespace and domain of namesrv
• [ISSUE-162]: support multi namesrv
• [ISSUE-207]: feat: support log level and log path
• [ISSUE-209]: feat: support hashQueueSelector
• [ISSUE-272]: structured Log
• [ISSUE-290]: add SetLogger method
• [ISSUE-301]: add GET_CONSUMER_RUNNING_INFO handler

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

• [ISSUE-120]: fix ci file
• [ISSUE-131]: update ci config
• [ISSUE-170]: add ASF header for some source file
• [ISSUE-185]: fix errors of comments and spelling
• [ISSUE-278]: remove extra json tag
• [ISSUE-279]: unify name of request header