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 |
|
yukun
|
fd436207bd
|
[skip e2e]Add comment for rmq message (#13633)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-12-17 22:38:47 +08:00 |
|
yukun
|
0456188dea
|
[skip e2e]Add comment for rmq message (#13628)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-12-17 22:12:54 +08:00 |
|
yukun
|
a30f422a4c
|
[skip e2e]Add comment for rmq id (#13637)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-12-17 22:10:50 +08:00 |
|
yukun
|
c55d49f732
|
[skip e2e]Add comment for rmq message (#13627)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-12-17 19:28:41 +08:00 |
|
yukun
|
d382d596da
|
[skip e2e]Add comment for rmq reader (#13625)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-12-17 19:13:06 +08:00 |
|
yukun
|
426f73ce07
|
[skip ci]Add comment for rocksmq reader (#13014)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-12-08 20:45:35 +08:00 |
|
yukun
|
490f8b50e1
|
[skip ci]Add comment for rocksmq reader (#13013)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-12-08 20:43:24 +08:00 |
|
Bingyi Sun
|
e06a9aeabd
|
[skip ci]Improve comment for Subscribe (#12655)
Signed-off-by: sunby <bingyi.sun@zilliz.com>
Co-authored-by: sunby <bingyi.sun@zilliz.com>
|
2021-12-02 22:40:21 +08:00 |
|
Bingyi Sun
|
142df87575
|
[skip ci]Improve comment for CreateProducer (#12654)
Signed-off-by: sunby <bingyi.sun@zilliz.com>
Co-authored-by: sunby <bingyi.sun@zilliz.com>
|
2021-12-02 22:38:23 +08:00 |
|
Bingyi Sun
|
7b9cf61394
|
[skip ci]Change comment of CreateReader (#12653)
Signed-off-by: sunby <bingyi.sun@zilliz.com>
Co-authored-by: sunby <bingyi.sun@zilliz.com>
|
2021-12-02 22:36:31 +08:00 |
|
shaoyue
|
2b3762fa63
|
[skip ci] Add comments for pulsar_consumer.go (#12446)
Signed-off-by: shaoyue.chen <shaoyue.chen@zilliz.com>
|
2021-11-30 16:05:59 +08:00 |
|
yukun
|
6439887eb7
|
[skip ci]Add license in reader.go in mqclient (#12402)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-11-29 23:19:42 +08:00 |
|
godchen
|
e3f49858c5
|
Add subscription prefix (#12251)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-11-24 17:47:15 +08:00 |
|
Xiaofan
|
0aaa87a79a
|
Fix MsgStream inconsistent seek (#12042)
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
|
2021-11-24 10:25:15 +08:00 |
|
godchen
|
116a503b4a
|
From dml cp load delete msg (#12144)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-11-21 07:33:14 +08:00 |
|
yukun
|
2147507e89
|
Add reader implementation in rocksmq (#12137)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-11-20 20:57:13 +08:00 |
|
godchen
|
51b353b52c
|
Add msgstream reader (#12130)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-11-19 15:57:12 +08:00 |
|
godchen
|
f91e9c6dda
|
Add pulsar reader implementation (#11990)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-11-17 23:47:11 +08:00 |
|
godchen
|
a1d1b3d0b6
|
Add reader interface (#11973)
Signed-off-by: godchen <qingxiang.chen@zilliz.com>
|
2021-11-17 14:11:11 +08:00 |
|
congqixia
|
304bbd3e71
|
Add ConsumeAfterSeek interface (#11818)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
|
2021-11-15 18:17:10 +08:00 |
|
yukun
|
2c215a0be3
|
[skip ci]Add rmq_producer comment (#11346)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-11-05 21:59:10 +08:00 |
|
yukun
|
ab00fe90de
|
[skip ci]Add rmq_producer comment (#11345)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-11-05 21:57:21 +08:00 |
|
Xiaofan
|
a4715996ef
|
Fix Pulsar seek to latest may block forever (#11128)
Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
|
2021-11-05 14:55:44 +08:00 |
|
yukun
|
872f6f8a04
|
[skip ci]Add rmq client comments (#11271)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-11-04 20:49:20 +08:00 |
|
yukun
|
eda65381c2
|
[skip ci]Add rmq producer comments (#11272)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-11-04 20:45:17 +08:00 |
|
yukun
|
e817cfbae6
|
[skip ci]Add pulsar client comments (#11197)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>
|
2021-11-03 23:20:46 +08:00 |
|