Liu Jicong
|
8e3701df01
|
fix(tmq): memory leak
|
2022-05-21 21:36:26 +08:00 |
|
Liu Jicong
|
dacbfc03cd
|
test(tmq): enable drop table case
|
2022-05-20 23:24:51 +08:00 |
|
Liu Jicong
|
86580cec09
|
enh(tmq): remove old tmq_commit api
|
2022-05-19 10:57:40 +08:00 |
|
Liu Jicong
|
2216438c72
|
fix(stream): skip update tb uid for db topic
|
2022-05-19 10:26:42 +08:00 |
|
Liu Jicong
|
a696ed583a
|
test(stream): _wstartts should be reverse quoted
|
2022-05-18 21:23:06 +08:00 |
|
Liu Jicong
|
3f0e89cabd
|
feat(tmq): refine commit offset api
|
2022-05-17 22:16:26 +08:00 |
|
Liu Jicong
|
d7e34a6642
|
fix(tmq): set config
|
2022-05-13 18:39:37 +08:00 |
|
Liu Jicong
|
e1e571c7a9
|
enh: print_row str ends with 0
|
2022-05-12 23:18:00 +08:00 |
|
Liu Jicong
|
06853043bd
|
feat(tmq): add config msg.with.table.name
|
2022-05-12 14:57:58 +08:00 |
|
Liu Jicong
|
7ab2e76c35
|
feat(tmq): support get tb name
|
2022-05-12 11:31:56 +08:00 |
|
Liu Jicong
|
de939d589f
|
fix: memory error
|
2022-04-29 20:11:58 +08:00 |
|
Liu Jicong
|
4402833a82
|
fix: memory error
|
2022-04-29 16:35:59 +08:00 |
|
Liu Jicong
|
f542785687
|
remove case
|
2022-04-29 15:09:38 +08:00 |
|
Liu Jicong
|
5c36e4e519
|
fix: subscrption api
|
2022-04-29 14:34:30 +08:00 |
|
Liu Jicong
|
a5a10f7068
|
feat: tmq support show
|
2022-04-26 17:08:42 +08:00 |
|
Liu Jicong
|
5efa53e11f
|
Merge branch '3.0' into feature/tq
|
2022-04-26 14:49:30 +08:00 |
|
Liu Jicong
|
a14b8dcc99
|
enh(tmq): delayed task
|
2022-04-26 14:32:37 +08:00 |
afwerar
|
dce677a72d
|
fix(os): fix window compilation errors.
|
2022-04-26 14:11:16 +08:00 |
|
Liu Jicong
|
609b21647b
|
fix: msg with schema
|
2022-04-25 15:40:25 +08:00 |
|
Liu Jicong
|
ecf00f7f57
|
enable hb
|
2022-04-25 11:41:42 +08:00 |
|
Liu Jicong
|
06a370c8de
|
enh(tmq): remove topic out of db
|
2022-04-25 10:42:17 +08:00 |
|
Liu Jicong
|
32e9887664
|
feat(tmq): add push mode
|
2022-04-22 19:47:00 +08:00 |
|
Liu Jicong
|
3035ecd58e
|
add show topic
|
2022-04-22 14:26:36 +08:00 |
|
Liu Jicong
|
8b1e51d910
|
refactor(tmq): refine api
|
2022-04-21 10:52:10 +08:00 |
|
Liu Jicong
|
d75ab9b3ff
|
refactor
|
2022-04-20 21:36:55 +08:00 |
|
Liu Jicong
|
90b1527e5f
|
merge from 3.0
|
2022-04-14 15:25:43 +08:00 |
|
Liu Jicong
|
7adb395b85
|
enh: add connection type for tmq
|
2022-04-14 14:42:51 +08:00 |
|
Liu Jicong
|
0fe0d6fc77
|
fix: fix tmq result parse
|
2022-04-13 20:37:51 +08:00 |
|
Liu Jicong
|
03d7201d47
|
feat: support tmq msg parse
|
2022-04-13 16:00:30 +08:00 |
|
Liu Jicong
|
cf33a822b9
|
fix type convert
|
2022-04-12 13:39:52 +08:00 |
|
Liu Jicong
|
3e5da8bedb
|
fix
|
2022-03-31 15:52:54 +08:00 |
|
Liu Jicong
|
4fd6f59092
|
stream set multi input
|
2022-03-29 15:24:25 +08:00 |
|
Liu Jicong
|
06285a252e
|
refactor tmq container
|
2022-03-26 20:12:45 +08:00 |
|
Liu Jicong
|
82c141ede8
|
merge from 3.0
|
2022-03-01 15:56:11 +08:00 |
|
Liu Jicong
|
48283e42e9
|
new offset management
|
2022-02-23 16:04:06 +08:00 |
|
Liu Jicong
|
82bcecc4ff
|
add stream mode config
|
2022-02-18 16:59:33 +08:00 |
|
Liu Jicong
|
7bbca5e4b5
|
add tmq reset offset
|
2022-02-17 19:07:39 +08:00 |
|
Liu Jicong
|
d0a61176a3
|
add auto commit
|
2022-02-16 14:36:19 +08:00 |
|
Liu Jicong
|
684558f9d9
|
add perf test
|
2022-02-15 15:33:36 +08:00 |
|
Liu Jicong
|
f36f1a8216
|
temporary remove multi topic consume
|
2022-02-15 14:57:42 +08:00 |
|
Liu Jicong
|
f51295a23c
|
seperate rebalance msg from set conn msg
|
2022-02-12 11:28:22 +08:00 |
|
Liu Jicong
|
f0d7d1b323
|
mq rebalance
|
2022-02-11 18:09:25 +08:00 |
|
Liu Jicong
|
42da4f6fdd
|
rewrite rebalance
|
2022-02-11 16:24:38 +08:00 |
|
Liu Jicong
|
8b7ca94295
|
remove tmqTest out of clientTest
|
2022-02-08 10:20:41 +08:00 |
|
Liu Jicong
|
573aad5cc1
|
fix uninitialized
|
2022-02-03 19:47:27 +08:00 |
|
Liu Jicong
|
174378ad2b
|
add demo for tmq
|
2022-01-29 09:56:05 +08:00 |