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 |
|
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 |
|
jaime
|
ed3c29eae7
|
Support Kafka (#16149)
Signed-off-by: yun.zhang <yun.zhang@zilliz.com>
|
2022-04-12 19:47:33 +08:00 |
|