Commit Graph

120 Commits (6d9612d224b5d7c365730a81c7b445dcbe1bf6d6)

Author SHA1 Message Date
Bingyi Sun c877f33084
Downgrade pulsar client (#15325)
Signed-off-by: sunby <bingyi.sun@zilliz.com>

Co-authored-by: sunby <bingyi.sun@zilliz.com>
2022-01-20 22:25:38 +08:00
congqixia 1e61112b5a
Add retry logic in pulsar consumer unsubscribe (#15284)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
2022-01-20 01:23:37 +08:00
bigsheeper 7f775096c5
Unsubscribe when close pulsar consumer (#15221)
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
2022-01-17 18:53:36 +08:00
edward.zeng 08bb5b3b75
[skip e2e] Update mqclient rmq id test license (#15079)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-10 13:35:55 +08:00
edward.zeng bf804d74bf
[skip e2e] Update mqclient rmq id license (#15078)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-10 13:34:04 +08:00
edward.zeng 1b96086285
[skip e2e] Update mqclient rmq consumer license (#15077)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-10 13:32:04 +08:00
edward.zeng 6d86d80dcb
[skip e2e] Update mqclient rmq client license (#15007)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-07 18:49:25 +08:00
edward.zeng 2e012fa99f
[skip e2e] Update mqclient reader license (#15006)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-07 18:45:28 +08:00
edward.zeng 718564927d
[skip e2e] Update mqclient rmq client test license (#15008)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-07 18:43:21 +08:00
shaoyue 19bb516aab
[skip e2e] Fix comment typo for mqclient message (#14988)
Signed-off-by: shaoyue.chen <shaoyue.chen@zilliz.com>
2022-01-07 13:29:28 +08:00
yukun ae27be637d
[skip e2e]Add comment for pulsar producer (#14945)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2022-01-07 09:51:28 +08:00
yukun 7b873602c1
[skip e2e]Add comment for pulsar client (#14944)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2022-01-07 09:49:34 +08:00
edward.zeng 7bda81d050
[skip e2e] Update mqclient pulsar reader test license (#14933)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-06 18:17:54 +08:00
edward.zeng 81ccade3f3
[skip e2e] Add license for mqclient pulsar reader (#14932)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-06 18:16:03 +08:00
edward.zeng 04f7f7ce2a
[skip e2e] Update mqclient pulsar producer test license (#14931)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-06 18:14:07 +08:00
edward.zeng eb468b09a5
[skip e2e] Update mqclient pulsar message license (#14859)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-06 09:39:25 +08:00
edward.zeng 1c7e8bbcaf
[skip e2e] Update mqclient pulsar id test license (#14858)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-05 18:57:21 +08:00
edward.zeng 4b58c4f42a
[skip e2e] Update mqclient pulsar producer license (#14860)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-05 17:19:20 +08:00
congqixia 921501dfac
Fail fast when pulsar subscribe exlusive timeout (#14844)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
2022-01-05 16:19:20 +08:00
edward.zeng 03037f4ea7
[skip e2e] Update mqclient pulsar consumer test license (#14777)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-04 20:07:24 +08:00
edward.zeng e11e26ab54
[skip e2e] Update mqclient pulsar id license (#14778)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-04 19:04:12 +08:00
edward.zeng 672d05a37a
[skip e2e] Update mqclient pulsar client test license (#14776)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2022-01-04 19:03:29 +08:00
godchen 9e51591b3a
Fix pulsar reader not close (#14543)
Signed-off-by: godchen0212 <qingxiang.chen@zilliz.com>
2022-01-04 14:45:19 +08:00
edward.zeng 4b6d99a2c1
[skip e2e] Update mqclient pulsar comsumer util license (#14674)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2021-12-31 14:35:31 +08:00
edward.zeng a7715051ce
[skip e2e] Update mqclient pulsar client util license (#14670)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2021-12-31 14:29:44 +08:00
edward.zeng fbcfdb59b0
[skip e2e] Update mqclient producer util license (#14669)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2021-12-31 14:09:48 +08:00
edward.zeng 000c675c7a
[skip e2e] Update mqclient message util license (#14598)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2021-12-30 14:51:32 +08:00
edward.zeng 639152913f
[skip e2e] Update mqclient id util license (#14597)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2021-12-30 14:49:48 +08:00
edward.zeng 9abc94dfab
[skip e2e] Update mqcient consumer util license (#14596)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2021-12-30 14:48:04 +08:00
edward.zeng 5e7ce3502c
[skip e2e] Fix license in mqclient util (#14533)
Signed-off-by: Edward Zeng <jie.zeng@zilliz.com>
2021-12-29 17:49:47 +08:00
Xiaofan 029b153259
Remove data directory for test (#14363)
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
2021-12-29 10:08:47 +08:00
yukun 4ba974d193
Rocksmq client should be closed when close a msgstream (#13865)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-29 10:04:57 +08:00
yukun c76ae203ec
[skip e2e]Add comment for pulsar client (#14362)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-28 18:56:09 +08:00
yukun c61bcdf40e
[skip e2e]Add comment for pulsar client (#14360)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-28 18:52:08 +08:00
yukun bb86ab33ce
[skip e2e]Add comment for pulsar client (#14361)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-28 09:36:13 +08:00
yukun 7297ed105c
[skip e2e]Add comment for mq client (#14199)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-25 09:38:19 +08:00
yukun 65c19cb869
[skip e2e]Add comment for pulsar client (#14197)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-25 09:36:30 +08:00
yukun 9be7192cf5
[skip e2e]Add comment for pulsar client (#14196)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-25 09:34:38 +08:00
yukun 325639a2cb
[skip e2e]Add comment for pulsar client (#14198)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-25 09:32:32 +08:00
yukun 94745ba3c3
[skip e2e]Add comment for pulsar reader (#14119)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-24 11:01:19 +08:00
yukun 5d3eb75762
[skip e2e]Add comment for pulsar reader (#14118)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-24 10:57:30 +08:00
yukun 92c8d1ab1e
[skip e2e]Add comment for rocksmq reader (#14117)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-24 10:55:40 +08:00
yukun 5f5c764e54
[skip e2e]Add comment for rocksmq producer (#14116)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-24 10:53:50 +08:00
yukun e19708566f
[skip e2e]Add comment for pulsar reader (#14114)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-24 10:51:55 +08:00
yukun 9a8f53fb5f
[skip e2e]Add comment for rocksmq client (#14115)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-24 10:47:56 +08:00
yukun 5a4dc83e52
[skip e2e]Add comment for pulsar reader (#14113)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-23 22:15:27 +08:00
yukun ee2027be87
[skip e2e]Add comment for rmq reader (#13624)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-23 17:05:13 +08:00
yukun 95e06a0f57
[skip e2e]Add comment for rmq reader (#13638)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-20 15:41:01 +08:00
yukun 2fc6db7973
[skip e2e]Add comment for rmq create reader (#13639)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-17 22:42:42 +08:00
yukun 2436548493
[skip e2e]Add comment for rmq message (#13629)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-12-17 22:40:47 +08:00