rocketmq-client-go.git
3 days agoupdate introduction.md (#913) master
Oliver [Wed, 21 Sep 2022 07:07:33 +0000 (15:07 +0800)] 
update introduction.md (#913)

3 weeks agofix consumer stopped consuming when panic in consumeListener (#910)
cserwen [Thu, 1 Sep 2022 11:53:26 +0000 (19:53 +0800)] 
fix consumer stopped consuming when panic in consumeListener (#910)

Co-authored-by: dengzhiwen1 <dengzhiwen1@xiaomi.com>
3 weeks agowhen queue dropped,should'not consume the process queue.(#905) (#906)
Nick [Thu, 1 Sep 2022 11:52:22 +0000 (19:52 +0800)] 
when queue dropped,should'not consume the process queue.(#905) (#906)

* when queue dropped,should'not consume the process queue.(#905)

* poll method use private properties

3 weeks agofix:when msgCh full,can't release the pq.mutex lock,removeMessage method will blocked...
Nick [Thu, 1 Sep 2022 11:50:33 +0000 (19:50 +0800)] 
fix:when msgCh full,can't release the pq.mutex lock,removeMessage method will blocked. (#903)

4 weeks ago[ISSUE #907]remove useless stats log
Nick [Fri, 26 Aug 2022 07:54:42 +0000 (15:54 +0800)] 
[ISSUE #907]remove useless stats log

4 weeks ago[ISSUE #901]Close the traceDispatcher when producer or consumer is shutdown (#902)
zhangjidi2016 [Wed, 24 Aug 2022 07:44:15 +0000 (15:44 +0800)] 
[ISSUE #901]Close the traceDispatcher when producer or consumer is shutdown (#902)

Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
4 weeks ago[ISSUE #899]Fix the groupName takes the namespace prefix (#900)
zhangjidi2016 [Wed, 24 Aug 2022 07:43:25 +0000 (15:43 +0800)] 
[ISSUE #899]Fix the groupName takes the namespace prefix (#900)

Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
4 weeks ago[ISSUE #845] support standard json
yuz10 [Tue, 23 Aug 2022 03:44:12 +0000 (11:44 +0800)] 
[ISSUE #845] support standard json

[ISSUE #845] support standard json

4 weeks ago(feat): add user defined topic dimension consumer limiter (#895)
Robin Han [Mon, 22 Aug 2022 11:27:42 +0000 (19:27 +0800)] 
(feat): add user defined topic dimension consumer limiter (#895)

Co-authored-by: wumu.hx <wumu.hx@antfin.com>
4 weeks agofix consumer doesn't consume message because of blocked on Lock in some case (#898)
givemeafish [Mon, 22 Aug 2022 09:06:59 +0000 (17:06 +0800)] 
fix consumer doesn't consume message because of blocked on Lock in some case (#898)

5 weeks ago(feat): add filter hooks (#891)
Robin Han [Fri, 19 Aug 2022 03:15:13 +0000 (11:15 +0800)] 
(feat): add filter hooks (#891)

Co-authored-by: wumu.hx <wumu.hx@antfin.com>
5 weeks agoUpdate readme file according to the new features in the latest release version. ...
dinglei [Wed, 17 Aug 2022 11:07:07 +0000 (19:07 +0800)] 
Update readme file according to the new features in the latest release version. (#893)

5 weeks ago[ISSUE #862] Update client version in Readme file.
dinglei [Wed, 17 Aug 2022 09:43:17 +0000 (17:43 +0800)] 
[ISSUE #862] Update client version in Readme file.

close #862

6 weeks agofeat: support lite pull consumer (#881)
Nick [Sat, 13 Aug 2022 06:05:06 +0000 (14:05 +0800)] 
feat: support lite pull consumer (#881)

* feat: support lite pull consumer

* remove the real ip.

* go.mod require go 1.13,so remove old versions.

* 1.no need to persist offset,rocketmq client do it when start;2.add pprof.

* Update .travis.yml

Co-authored-by: dinglei <libya_003@163.com>
6 weeks ago[feat] fix query not found (#886)
Xuexue [Sun, 7 Aug 2022 07:31:43 +0000 (15:31 +0800)] 
[feat] fix query not found (#886)

6 weeks agoAdd param which like consumeThreadMin of java sdk to control consumption rate (#883)
cserwen [Sun, 7 Aug 2022 07:29:56 +0000 (15:29 +0800)] 
Add param which like consumeThreadMin of java sdk to control consumption rate (#883)

* add param which like consumeThreadMin of java sdk to control consumption rate

* make some configs can be set for push_consumer

Co-authored-by: dengzhiwen1 <dengzhiwen1@xiaomi.com>
7 weeks ago [ISSUE #884]fix goroutine leak (#885)
Nick [Sat, 6 Aug 2022 01:02:18 +0000 (09:02 +0800)] 
 [ISSUE #884]fix goroutine leak (#885)

* [ISSUE #884]fix goroutine leak

* mock UnregisterConsumer

7 weeks agokeep queryTopicRouteInfoFromServer timeout the same as Java (#880)
WeizhongTu [Wed, 3 Aug 2022 09:10:47 +0000 (17:10 +0800)] 
keep queryTopicRouteInfoFromServer timeout the same as Java (#880)

[ISSUE #882] keep queryTopicRouteInfoFromServer timeout the same as Java.

7 weeks agoclean expired message in CLUSTERING model for push_consumer (#879)
cserwen [Wed, 3 Aug 2022 07:11:55 +0000 (15:11 +0800)] 
clean expired message in CLUSTERING model for push_consumer (#879)

Co-authored-by: dengzhiwen1 <dengzhiwen1@xiaomi.com>
7 weeks ago[ISSUE #876] Safely checking context in trace producer. (#863)
Xuexue [Sun, 31 Jul 2022 14:57:20 +0000 (22:57 +0800)] 
[ISSUE #876] Safely checking context in trace producer.  (#863)

* [feat] /safely producer ctx

* [feat] safely producterCtx

8 weeks agoUpdate release date link in readme file.
dinglei [Thu, 28 Jul 2022 08:26:41 +0000 (16:26 +0800)] 
Update release date link in readme file.

2 months agoMerge pull request #873 from ShannonDing/codecove_failed release-v2.1.1 v2.1.1 v2.1.1-rc3
Heng Du [Mon, 25 Jul 2022 11:05:22 +0000 (19:05 +0800)] 
Merge pull request #873 from ShannonDing/codecove_failed

[ISSUE #872] fix code coverage shell error in travis ci yml.

2 months agofix code coverage shell error in travis ci yml. 873/head
ShannonDing [Mon, 25 Jul 2022 09:46:05 +0000 (17:46 +0800)] 
fix code coverage shell error in travis ci yml.

2 months ago[ISSUE #870] add license header for some new files. (#871)
dinglei [Mon, 25 Jul 2022 09:44:57 +0000 (17:44 +0800)] 
[ISSUE #870] add license header for some new files. (#871)

* add license header for some new files.

* Rollback rlog and testify version to support go 1.11 and go 1.12

2 months ago[ISSUE #790] use uber atomic lib to avoid atomic value data race. (#866)
WJL3333 [Mon, 25 Jul 2022 08:20:39 +0000 (16:20 +0800)] 
[ISSUE #790] use uber atomic lib to avoid atomic value data race. (#866)

* use uber atomic lib to avoid atomic value data race.

* change wrong sub value

Co-authored-by: dinglei <libya_003@163.com>
2 months agoFix: api comments (#867)
Laurence [Mon, 25 Jul 2022 08:12:14 +0000 (16:12 +0800)] 
Fix: api comments (#867)

2 months agoupdate rlog to 1.9.0 to fix CVE-2022-29526 in (#868)
dinglei [Mon, 25 Jul 2022 07:02:43 +0000 (15:02 +0800)] 
update rlog to 1.9.0 to fix CVE-2022-29526 in (#868)

Co-authored-by: shannon.dl <shannon.dl@alibaba-inc.com>
2 months ago[ISSUE #728] client shutdown abnormally (#729)
zhangyang [Mon, 25 Jul 2022 06:29:18 +0000 (14:29 +0800)] 
[ISSUE #728] client shutdown abnormally (#729)

* [ISSUE #757] Fix GetHeader type conflict

Signed-off-by: zhangyang <Git_Yang@163.com>
* [ISSUE #728] Optimize client instance management

Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
* remove dupilcate "LogKeyProducerGroup" in rlog.

Co-authored-by: dinglei <libya_003@163.com>
2 months agoavoid sendmessage back with origin message body in request. (#865)
WJL3333 [Mon, 25 Jul 2022 02:09:29 +0000 (10:09 +0800)] 
avoid sendmessage back with origin message body in request. (#865)

2 months agoclose msgCh when pq droped (#859)
dinglei [Mon, 25 Jul 2022 02:00:34 +0000 (10:00 +0800)] 
close msgCh when pq droped (#859)

2 months agoFix msg lost if consumer crash when send msg back failed. (#860)
dinglei [Mon, 25 Jul 2022 01:59:39 +0000 (09:59 +0800)] 
Fix msg lost if consumer crash when send msg back failed. (#860)

Co-authored-by: shannon.dl <shannon.dl@alibaba-inc.com>
2 months agoa liitle improvement use chan instead (#854)
hYang [Thu, 21 Jul 2022 15:54:54 +0000 (23:54 +0800)] 
a liitle improvement use chan instead (#854)

2 months agofix request offset not changed in some case (#844)
cserwen [Thu, 21 Jul 2022 15:46:51 +0000 (23:46 +0800)] 
fix request offset not changed in some case (#844)

Co-authored-by: dengzhiwen1 <dengzhiwen1@xiaomi.com>
2 months agoadd some method for pushConsumer (#849)
cserwen [Thu, 21 Jul 2022 15:45:50 +0000 (23:45 +0800)] 
add some method for pushConsumer (#849)

Co-authored-by: dengzhiwen1 <dengzhiwen1@xiaomi.com>
2 months agofix pullThresholdSizeForTopic invalid (#814)
hjxp [Thu, 21 Jul 2022 12:55:15 +0000 (20:55 +0800)] 
fix pullThresholdSizeForTopic invalid (#814)

* fix pullThresholdSizeForTopic invalid

* fix code style

Co-authored-by: longjunhu <hulongjun@douyu.tv>
Co-authored-by: dinglei <libya_003@163.com>
2 months agofeat(fmt): compare slice length directly (#851)
j2gg0s [Thu, 21 Jul 2022 12:36:46 +0000 (20:36 +0800)] 
feat(fmt): compare slice length directly (#851)

2 months agofix bug when get `mqadmin consumerStatus` can't get consume status. (#812)
WJL3333 [Thu, 21 Jul 2022 12:32:15 +0000 (20:32 +0800)] 
fix bug when get `mqadmin consumerStatus` can't get consume status. (#812)

2 months agoconsumer consume include tag according to accumulation (#834)
wang1309 [Thu, 21 Jul 2022 12:07:52 +0000 (20:07 +0800)] 
consumer consume include tag according to accumulation (#834)

Co-authored-by: 王瑞 <wangrui5@songguo7.com>
2 months agofix primitive.WithMethod ctx transfer (#837)
胡同里有猫 [Thu, 21 Jul 2022 11:22:10 +0000 (19:22 +0800)] 
fix primitive.WithMethod ctx transfer (#837)

2 months agoRemove useless code in `encodeBatch()` (#783)
Zero [Thu, 21 Jul 2022 09:32:50 +0000 (17:32 +0800)] 
Remove useless code in `encodeBatch()` (#783)

2 months agosend csListLock *sync.Mutex to computeStatsData for lock csList (#820)
liumiaomiao [Thu, 21 Jul 2022 09:29:59 +0000 (17:29 +0800)] 
send csListLock *sync.Mutex to computeStatsData for lock csList (#820)

2 months agofix: takeMessages sleep 5s when no msg (#629)
Fei Yang [Thu, 21 Jul 2022 09:08:42 +0000 (17:08 +0800)] 
fix: takeMessages sleep 5s when no msg (#629)

https://github.com/apache/rocketmq-client-go/issues/628

2 months agoMerge pull request #856 from WJL3333/fix_trace_context_cancel_problem
Heng Du [Wed, 20 Jul 2022 04:47:23 +0000 (12:47 +0800)] 
Merge pull request #856 from WJL3333/fix_trace_context_cancel_problem

[ISSUE #774] Avoid cancel context too early cause trace data fail.

2 months agoMerge pull request #857 from weedge/fix/selectMessageQueue_nil
Heng Du [Tue, 19 Jul 2022 02:40:02 +0000 (10:40 +0800)] 
Merge pull request #857 from weedge/fix/selectMessageQueue_nil

fix: selectMessageQueue nil *internal.TopicPublishInfo

2 months agoMerge pull request #858 from georgehao/fix/message_util
Heng Du [Tue, 19 Jul 2022 02:39:33 +0000 (10:39 +0800)] 
Merge pull request #858 from georgehao/fix/message_util

feat: exchange messages_utils dir

2 months agofeat: exchange messages_utils dir 858/head
georgehao [Mon, 18 Jul 2022 16:32:59 +0000 (00:32 +0800)] 
feat: exchange messages_utils dir

2 months agofix: selectMessageQueue nil *internal.TopicPublishInfo 857/head
weedge [Mon, 18 Jul 2022 14:21:04 +0000 (22:21 +0800)] 
fix: selectMessageQueue nil *internal.TopicPublishInfo

2 months ago1. avoid cancel context too early cause trace data fail. 856/head
wangjinlong.1048576 [Mon, 18 Jul 2022 03:24:15 +0000 (11:24 +0800)] 
1. avoid cancel context too early cause trace data fail.

2 months agoMerge pull request #852 from NeonToo/fix/reset_offset
Heng Du [Wed, 13 Jul 2022 03:35:24 +0000 (11:35 +0800)] 
Merge pull request #852 from NeonToo/fix/reset_offset

bugfix rebalance is not paused after suspend and rebalance not trigge…

2 months agofix(sendOneWay): fix stack overflow caused by recursive calls (#773)
Wen Hu [Tue, 12 Jul 2022 06:27:32 +0000 (14:27 +0800)] 
fix(sendOneWay): fix stack overflow caused by recursive calls (#773)

Co-authored-by: huwen.alvin <huwen.alvin@bytedance.com>
2 months agobugfix rebalance is not paused after suspend and rebalance not trigged in resume 852/head
筱瑜 [Tue, 28 Jun 2022 17:27:20 +0000 (01:27 +0800)] 
bugfix rebalance is not paused after suspend and rebalance not trigged in resume

3 months ago[ISSUE #823]fix: panic problem caused by json-iterator in go1.18 (#841)
Yusan Kurban [Wed, 15 Jun 2022 01:59:50 +0000 (09:59 +0800)] 
[ISSUE #823]fix: panic problem caused by json-iterator in go1.18 (#841)

* fix: panic problem caused by json-iterator

* fix: keep go version in 1.13

Co-authored-by: yushan <shan.yu@shopee.com>
3 months ago[ISSUE #832] Client may submit wrong offset when network instability
AaronWang [Tue, 14 Jun 2022 09:19:54 +0000 (17:19 +0800)] 
[ISSUE #832] Client may submit wrong offset when network instability

Co-authored-by: chenhui <wangzhaohui@xiaohongshu.com>
3 months agoFeat/rpc request (#803)
georgehao [Fri, 27 May 2022 02:23:23 +0000 (10:23 +0800)] 
Feat/rpc request (#803)

* [Issue #778] Build instance name with nanosecond (#779)

[Issue #778] Build instance name with nanosecond (#779)

* Merge remote-tracking branch 'origin/master'

* Merge remote-tracking branch 'origin/master'

* feat: request reply producer

* feat: update

* feat: add consumer

* feat: fix ci

* feat: update

* feat: update

* feat: 修改request请求参数

* feat: modify async request for delete

* feat: fix go1.11 and go1.12 don't have time.Millseconds

* feat: move time.Millisecond() to duration/time.Millisecond

* feat: fix async request not remove requestResponseFutrue

Co-authored-by: chaiyx <chaiyx11@163.com>
Co-authored-by: Administrator <admin@example.com>
Co-authored-by: haohongfan1 <haohongfan1@jd.com>
Co-authored-by: dinglei <libya_003@163.com>
3 months agoMerge pull request #809 from yuz10/master
Heng Du [Thu, 26 May 2022 05:47:52 +0000 (13:47 +0800)] 
Merge pull request #809 from yuz10/master

[ISSUE #810] fix async producer example

3 months agoMerge pull request #825 from cserwen/consumer_option
Heng Du [Thu, 26 May 2022 05:47:14 +0000 (13:47 +0800)] 
Merge pull request #825 from cserwen/consumer_option

fix some params for consumer can not be changed

3 months agoMerge pull request #826 from WJL3333/support_goroutine_stack
Heng Du [Thu, 26 May 2022 05:46:42 +0000 (13:46 +0800)] 
Merge pull request #826 from WJL3333/support_goroutine_stack

[ISSUE #827] Support get consumerRunningInfo return goroutine stack

3 months agoMerge pull request #829 from WJL3333/support_log_rotate
Heng Du [Thu, 26 May 2022 05:46:31 +0000 (13:46 +0800)] 
Merge pull request #829 from WJL3333/support_log_rotate

[ISSUE #828] Support rlog rotate

4 months ago1. support rlog rotate 829/head
wangjinlong.1048576 [Fri, 13 May 2022 10:55:14 +0000 (18:55 +0800)] 
1. support rlog rotate

4 months ago1. support get consumerRunningInfo return goroutine stack 826/head
wangjinlong.1048576 [Fri, 13 May 2022 10:11:57 +0000 (18:11 +0800)] 
1. support get consumerRunningInfo return goroutine stack

4 months agofix some params for consumer can not be changed 825/head
cserwen [Thu, 12 May 2022 09:20:03 +0000 (17:20 +0800)] 
fix some params for consumer can not be changed

4 months agoMerge pull request #824 from cserwen/fix_flow
Heng Du [Tue, 10 May 2022 02:10:57 +0000 (10:10 +0800)] 
Merge pull request #824 from cserwen/fix_flow

fix queueMaxSpanFlowControlTimes not change

4 months agofix queueMaxSpanFlowControlTimes not change 824/head
cserwen [Sat, 7 May 2022 08:58:23 +0000 (16:58 +0800)] 
fix queueMaxSpanFlowControlTimes not change

5 months agoMerge pull request #679 from trxo/master
zhangyang [Mon, 25 Apr 2022 05:45:50 +0000 (13:45 +0800)] 
Merge pull request #679 from trxo/master

[ISSUE #818] fix msg.Body compressed cause error in transaction message processing

5 months agoMerge pull request #816 from WJL3333/fix_tcp_write_block
xujianhai666 [Sat, 23 Apr 2022 07:41:10 +0000 (15:41 +0800)] 
Merge pull request #816 from WJL3333/fix_tcp_write_block

fix long time block when remote endpoint crash.

5 months agoMerge branch 'master' of github.com:apache/rocketmq-client-go 679/head
trxo [Thu, 21 Apr 2022 15:30:43 +0000 (23:30 +0800)] 
Merge branch 'master' of github.com:apache/rocketmq-client-go

5 months ago1. fix ci 816/head
wangjinlong.1048576 [Thu, 21 Apr 2022 11:38:26 +0000 (19:38 +0800)] 
1. fix ci

5 months ago1. make tcp relate param configurable
wangjinlong.1048576 [Thu, 21 Apr 2022 08:15:01 +0000 (16:15 +0800)] 
1. make tcp relate param configurable

5 months ago1. add log when close socket.
wangjinlong.1048576 [Thu, 21 Apr 2022 07:14:03 +0000 (15:14 +0800)] 
1. add log when close socket.

5 months ago1. remove request from responseTable when sendAsync
wangjinlong.1048576 [Thu, 21 Apr 2022 02:59:03 +0000 (10:59 +0800)] 
1. remove request from responseTable when sendAsync
2. change default read/write Deadline to 120 sec.
3. close connection when set deadline fail.

5 months ago1. add tcp conn write and read deadline to avoid long time block socket ops when...
wangjinlong.1048576 [Wed, 20 Apr 2022 12:13:47 +0000 (20:13 +0800)] 
1. add tcp conn write and read deadline to avoid long time block socket ops when remote endpoint crash.
2. enable tcp keep alive.

5 months agofix async producer example 809/head
yuz10 [Thu, 14 Apr 2022 16:27:56 +0000 (00:27 +0800)] 
fix async producer example

5 months ago[ISSUE #807] fix code style (#808)
zhangyang [Thu, 14 Apr 2022 15:44:41 +0000 (23:44 +0800)] 
[ISSUE #807] fix code style (#808)

Signed-off-by: zhangyang <Git_Yang@163.com>
5 months agoFix the feature that GetNamesrv (#805)
guyinyou [Wed, 13 Apr 2022 09:17:09 +0000 (17:17 +0800)] 
Fix the feature that GetNamesrv (#805)

* Refactor the client instance struct,converge the namesrv module

* fix the feature that GetNamesrv(clientId)

6 months ago[ISSUE #787]Refactor the client instance struct,converge the namesrv module (#788)
guyinyou [Tue, 15 Mar 2022 07:28:39 +0000 (15:28 +0800)] 
[ISSUE #787]Refactor the client instance struct,converge the namesrv module (#788)

6 months ago[Issue #778] Build instance name with nanosecond (#779)
chaiyx [Wed, 9 Mar 2022 06:08:13 +0000 (14:08 +0800)] 
[Issue #778] Build instance name with nanosecond (#779)

[Issue #778] Build instance name with nanosecond (#779)

6 months agoMerge pull request #775 from hnlq715/fix/update-gjson
Heng Du [Tue, 8 Mar 2022 06:59:54 +0000 (14:59 +0800)] 
Merge pull request #775 from hnlq715/fix/update-gjson

fix: update gjson for security problem

7 months agofix: update gjson for security problem 775/head
大可 [Sat, 29 Jan 2022 03:18:29 +0000 (11:18 +0800)] 
fix: update gjson for security problem

8 months agoecho message on codecov failed to upload
dinglei [Wed, 19 Jan 2022 03:55:17 +0000 (11:55 +0800)] 
echo message on codecov failed to upload

8 months agoUpdate year to 2022.
dinglei [Wed, 19 Jan 2022 03:49:04 +0000 (11:49 +0800)] 
Update year to 2022.

8 months ago[ISSUE #759]
WJL3333 [Mon, 3 Jan 2022 12:50:55 +0000 (20:50 +0800)] 
[ISSUE #759]

ISSUE #759] Change ResetOffsetBody response parse method to support fastjson schema

9 months ago[ISSUE #726] feat: replace fmt to rlog (#756)
yuanmoon [Wed, 22 Dec 2021 08:09:52 +0000 (16:09 +0800)] 
[ISSUE #726] feat: replace fmt to rlog (#756)

* Replace fmt to rlog

9 months ago[ISSUE #757] Fix GetHeader type conflict (#758)
zhangyang [Wed, 22 Dec 2021 07:52:14 +0000 (15:52 +0800)] 
[ISSUE #757] Fix GetHeader type conflict (#758)

Signed-off-by: zhangyang <Git_Yang@163.com>
9 months ago[ISSUE #752] change argument to pointer-like to avoid allocations
xuweiwei [Wed, 15 Dec 2021 10:23:58 +0000 (18:23 +0800)] 
[ISSUE #752] change argument to pointer-like to avoid allocations

Signed-off-by: xuweiwei <xuweiwei_yewu@cmss.chinamobile.com>
9 months agoUpdate stale.yml
von gosling [Wed, 15 Dec 2021 01:55:25 +0000 (09:55 +0800)] 
Update stale.yml

9 months agoUpdate README.md
von gosling [Wed, 15 Dec 2021 01:39:55 +0000 (09:39 +0800)] 
Update README.md

9 months agoDelete .github/.github directory
von gosling [Wed, 15 Dec 2021 01:19:05 +0000 (09:19 +0800)] 
Delete .github/.github directory

9 months agoAdd workflow
vongosling [Wed, 15 Dec 2021 01:09:11 +0000 (09:09 +0800)] 
Add workflow

9 months agoFix building error temporarily
von gosling [Tue, 14 Dec 2021 14:11:43 +0000 (22:11 +0800)] 
Fix building error temporarily

9 months agoUpdate README.md
von gosling [Tue, 14 Dec 2021 13:51:36 +0000 (21:51 +0800)] 
Update README.md

9 months ago[ISSUE #744] check multiple topics in one batch
Oreoreoreo [Wed, 1 Dec 2021 00:37:26 +0000 (08:37 +0800)] 
[ISSUE #744] check multiple topics in one batch

Co-authored-by: maoruilei3120 <maoruilei3120@ipalfish.com>
9 months agoRemove useless comments
vongosling [Mon, 29 Nov 2021 07:27:45 +0000 (15:27 +0800)] 
Remove useless comments

9 months agoUpdate README.md
von gosling [Mon, 29 Nov 2021 07:09:57 +0000 (15:09 +0800)] 
Update README.md

9 months agoCGo version has been deprecated
von gosling [Mon, 29 Nov 2021 07:06:06 +0000 (15:06 +0800)] 
CGo version has been deprecated

9 months agofix: correctly mark messages to be reconsumed (#693)
fluyu [Sun, 28 Nov 2021 04:23:21 +0000 (12:23 +0800)] 
fix: correctly mark messages to be reconsumed (#693)

10 months ago[offset] Optimize the update offset logic (#732)
zhangyang [Mon, 15 Nov 2021 05:11:04 +0000 (13:11 +0800)] 
[offset] Optimize the update offset logic (#732)

Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
10 months ago[ISSUE #735] centralized management errors (#708)
180909 [Wed, 3 Nov 2021 04:59:29 +0000 (12:59 +0800)] 
[ISSUE #735] centralized management errors (#708)

* centralized management errors

* update missed

* update missed

* fix import cycle

* go fmt

12 months agofix the bug caused in HA cluster in consumer (#723) v2.1.1-rc2 v2.1.1-rc2
guyinyou [Fri, 10 Sep 2021 03:20:40 +0000 (11:20 +0800)] 
fix the bug caused in HA cluster in consumer (#723)

12 months ago(fix): set subversion when #Subscribe (#720)
Robin Han [Mon, 30 Aug 2021 03:36:28 +0000 (11:36 +0800)] 
(fix): set subversion when #Subscribe (#720)

12 months agoUpdate NOTICE
von gosling [Sat, 28 Aug 2021 01:55:35 +0000 (09:55 +0800)] 
Update NOTICE