milvus

Commit Graph

Author	SHA1	Message	Date
jaime	6e7831470c	Revert settings of Pulsar address and refine config code (#18494 ) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>	2022-08-02 21:26:33 +08:00
jaime	3ec147acfe	Upgrade confluent kafka go version to 1.9.1 (#18293 ) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>	2022-07-22 13:28:28 +08:00
congqixia	d90308e9a0	Handle topic not exist in rqm & mqtt seek (#18314 ) Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>	2022-07-20 15:42:29 +08:00
Xiaofan	653dce4948	Fix pulsar error check (#18207 ) Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>	2022-07-11 10:56:25 +08:00
Jiquan Long	6df47c7faf	Change pulsar compression type to zstd-faster (#18121 ) Signed-off-by: longjiquan <jiquan.long@zilliz.com>	2022-07-07 11:16:22 +08:00
Jiquan Long	44024c1b1d	Replace pulsar compression type zstd with lz4 (#18085 ) Signed-off-by: longjiquan <jiquan.long@zilliz.com>	2022-07-05 22:06:21 +08:00
jaime	762e3b78a6	support configurable sasl mechanisms for kafka (#17542 ) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>	2022-06-29 10:32:17 +08:00
Xiaofan	1f6fbf91b2	Fix pulsar unsubsribe issue (#17562 ) Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>	2022-06-16 17:28:11 +08:00
jaime	dbef4c6ec2	Align kafka consume from latest with puslar and rocksmq (#17433 ) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>	2022-06-08 19:00:07 +08:00
jaime	5698bf4236	Add sasl configurations for kafka (#17323 ) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>	2022-06-02 12:12:03 +08:00
bigsheeper	e0cbacba59	Check ignorable error to prevent unnecessary panic (#17317 ) Signed-off-by: bigsheeper <yihao.dai@zilliz.com>	2022-06-02 10:12:03 +08:00
jaime	a20e0dfc74	Refactor kafka msgstream implementation (#17069 ) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>	2022-05-23 12:39:58 +08:00
jaime	328ab7ecf6	Fix kafka client hang after killing broker pod of parition leader (#16983 ) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>	2022-05-14 23:05:54 +08:00
Xiaofan	000c5ff3de	Fix msgstream unsubscription (#16883 ) Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>	2022-05-10 19:43:52 +08:00
Xiaofan	62658dcda6	Fix pulsar unscubsribe fail because of consumer not found (#16839 ) Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>	2022-05-09 12:07:52 +08:00
jaime	bb9ccbb7e2	Use a singleton kafka producer (#16739 ) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>	2022-04-29 17:29:47 +08:00
yah01	2022a361c0	Enable ZSTD compression for pulsar (#16014 ) Signed-off-by: yah01 <yang.cen@zilliz.com>	2022-04-24 10:25:43 +08:00
jaime	ed3c29eae7	Support Kafka (#16149 ) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>	2022-04-12 19:47:33 +08:00
godchen	bb7a0766fe	Add dependency factory (#16204 ) Signed-off-by: godchen0212 <qingxiang.chen@zilliz.com>	2022-04-07 22:05:32 +08:00
jaime	97b1ed7bca	Remove reader API from Mqstream and replace it with consumer API (#15971 ) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>	2022-03-15 14:45:22 +08:00
jaime	7a3a721380	Reconstruct mqstream module (#15784 ) Signed-off-by: yun.zhang <yun.zhang@zilliz.com>	2022-03-03 21:57:56 +08:00

21 Commits (index)