v2.1.2

What's Changed

• [ISSUE #876] Safely checking context in trace producer. by @aireet in #863
• [ISSUE #878] Clean expired message in CLUSTERING model for push_consumer by @cserwen in #879
• [ISSUE #882] keep queryTopicRouteInfoFromServer timeout the same as Java by @twz915 in #880
• [ISSUE #884]fix goroutine leak by @lampnick in #885
• Add param which like consumeThreadMin of java sdk to control consumption rate by @cserwen in #883
• [feat] fix query not found by @aireet in #886
• feat: support lite pull consumer by @lampnick in #881
• [ISSUE #862]Update readme file according to the new features in the latest release version. by @ShannonDing in #893
• ISSUE #894: add filter hooks in consumer. by @superhx in #891
• [ISSUE #897] fix consumer doesn't consume message because of blocked on Lock by @wangzeping722 in #898
• (feat): add user defined topic dimension consumer limiter by @superhx in #895
• [ISSUE #845] support standard json by @yuz10 in #846
• [ISSUE #899]Fix the groupName takes the namespace prefix by @zhangjidi2016 in #900
• [ISSUE #901]Close the traceDispatcher when producer or consumer is shutdown by @zhangjidi2016 in #902
• [ISSUE #907]remove useless stats log (#907) by @lampnick in #908
• [ISSUE #904] fix:pq.mutex lock blocked. by @lampnick in #903
• when queue dropped,should'not consume the process queue.(#905) by @lampnick in #906
• [ISSUE #909] Fix consumer stopped consuming when panic in consumeListener by @cserwen in #910
• [ISSUE #912] Update introduction.md by @Oliverwqcwrw in #913
• [ISSUE #922]close file after it was read in internal fiel utils. by @zc24 in #925
• [ISSUE #926] don't share limit channel in pushConsumer by @aireet in #923
• [ISSUE #929] Correct struct comment by @Oliverwqcwrw in #930
• [ISSUE #945]init crCh after topic with namespace to avoid consumption blocked. by @NeonToo in #944
• [ISSUE #939]Pull or poll message support message trace by @zhangjidi2016 in #940
• [ISSUE #935]fix consumer option validate by @0daypwn in #936
• [feat] incr instanceCount in once and fmt codes by @aireet in #888
• [ISSUE #942]correct name typo by @0daypwn in #943
• fix some spell mistakes by @weavernet in #949
• Fix response ResQueryNotFound typo by @jackedelic in #948
• [ISSUE #931] fix filter message by @0daypwn in #932
• [ISSUE #927] fix processQueue remove offset by @0daypwn in #928
• [ISSUE #953] fix limiter with goroutine cover by @maqingxiang in #952
• [ISSUE #956]fix reset offset remove pq by @0daypwn in #957
• push consumer enable getting offset diff map by @NeonToo in #964
• add api GetOffsetDiffMap by @NeonToo in #965
• [ISSUE #961] Fix: data race when update subversion for consumer by @cserwen in #962
• [ISSUE #975]when close consumer, return directly by @wenxuwan in #974
• [ISSUE #986]Reduce the log level when fetch offset success and remove unnecessary mq by @humkum in #987
• [ISSUE #970]fix:logic error when reset retry message's origin topic by @humkum in #971
• [ISSUE #996] invoke user callback and return error info when async process send resp error by @ferrirW in #997
• fix: client version mismatch by @qshuai in #1009
• [ISSUE #999]support admin topicList and groupList method by @Slideee in #1000
• [ISSUE #1002] fix: add log when send heartbeat failed by @cserwen in #1003
• [ISSUE #994] Fix: unlock all queues when consumer shutdown in orderly model by @cserwen in #1015
• Replacing github.com/satori/go.uuid with github.com/google/uuid by @BLAZZ in #972
• fix Panic when close traceDispatcher by @wenxuwan in #1027
• [ISSUE #989] consumer and producer client add unit support (WithUnitName) by @twz915 in #988
• Update README.md by @HubQin in #1026
• [ISSUE #1024] fix: unsubscribed topic queues not dropped by @wgdzlh in #1025
• [ISSUE #1034] fix: the message may be cleaned when the message has not been consumed. by @humkum in #1035
• fix "Batch send message can't auto create topic" by @francisoliverlee in #1040
• [ISSUE #1030] Avoid to append unexpected separator to message key by @gaofeihang in #1031
• empty subcribed topic is allowed to start by @NeonToo in #969
• fix wrong add for set when tags are set by @cserwen in #1001
• [ISSUE #1018] Fix unintended shutdown of shared rmqClient by @wgdzlh in #1019
• support RequestCode GET_CONSUMER_STATUS_FROM_CLIENT by @NeonToo in #985
• change ConsumeGoroutineNums max value allowed by @twz915 in #1049
• DomainWithUnit support existed query parameters by @twz915 in #1061
• [ISSUE #1056] fix: When the consumer and producer have the same topic, the consumer fails to update the topic. by @lvxiao1 in #1059
• [ISSUE #1013] Fix: select one message queue of different broker when retry to send by @cserwen in #1014
• run RebalanceImmediately with goroutine by @wenxuwan in #1081
• fix: topic pubishInfo and subscribeInfo not update by @redlsz in #1084

New Contributors

• @aireet made their first contribution in #863
• @wangzeping722 made their first contribution in #898
• @zhangjidi2016 made their first contribution in #900
• @Oliverwqcwrw made their first contribution in #913
• @zc24 made their first contribution in #925
• @0daypwn made their first contribution in #936
• @weavernet made their first contribution in #949
• @jackedelic made their first contribution in #948
• @maqingxiang made their first contribution in #952
• @humkum made their first contribution in #987
• @ferrirW made their first contribution in #997
• @qshuai made their first contribution in #1009
• @Slideee made their first contribution in #1000
• @BLAZZ made their first contribution in #972
• @HubQin made their first contribution in #1026
• @wgdzlh made their first contribution in #1025
• @francisoliverlee made their first contribution in #1040
• @gaofeihang made their first contribution in #1031
• @lvxiao1 made their first contribution in #1059
• @redlsz made their first contribution in #1084

Full Changelog: v2.1.1...v2.1.2