wangmm0220
|
71292f45ef
|
fix:data compatibility in tmq
|
2024-04-02 23:59:23 +08:00 |
|
wangmm0220
|
4dfc531e6c
|
opti:subscribe logic
|
2024-03-12 19:42:26 +08:00 |
|
wangmm0220
|
bb80866395
|
fix:memory leak
|
2024-03-08 14:49:48 +08:00 |
dapan1121
|
74f4cc9d2a
|
Merge pull request #24921 from taosdata/mark/tmq-3.0
fix:[TD-28869]get error in askEp because consumer is dropped when uns…
|
2024-03-04 09:27:47 +08:00 |
|
wangmm0220
|
e17832e27e
|
fix:[TD-28869]get error in askEp because consumer is dropped when unsubscribe
|
2024-02-29 14:38:09 +08:00 |
|
wangmm0220
|
eec6b66877
|
fix:[TD-28869]get error in askEp because consumer is dropped when unsubscribe topic
|
2024-02-28 17:05:11 +08:00 |
Haojun Liao
|
6bc12c8728
|
refactor: do some internal refactor.
|
2024-02-27 16:27:59 +08:00 |
|
dapan1121
|
794d4a931c
|
Merge pull request #24820 from taosdata/mark/3.0
fix:add excluded msg for meta in tmq
|
2024-02-23 09:41:39 +08:00 |
|
wangmm0220
|
c2c49a4b22
|
fix:change datablock to old version for compatibility
|
2024-02-22 19:01:58 +08:00 |
|
wangmm0220
|
604ae220f3
|
fix:change datablock to old version for compatibility
|
2024-02-22 17:48:33 +08:00 |
|
wangmm0220
|
6e13e4aa63
|
fix:add excluded msg for meta in tmq
|
2024-02-22 10:58:32 +08:00 |
|
wangmm0220
|
77e2500a81
|
fix:conflicts from 3.0
|
2024-02-19 18:46:31 +08:00 |
|
wangmm0220
|
478e1a67ae
|
fix:[TD-28590]add logic for consume excluded
|
2024-02-06 18:14:06 +08:00 |
|
wangmm0220
|
871ebfa7ba
|
Merge branch '3.0' of https://github.com/taosdata/TDengine into mark/3.0
|
2024-02-06 14:02:46 +08:00 |
|
wangmm0220
|
5796f411e4
|
Merge branch 'mark/3.0' of https://github.com/taosdata/TDengine into mark/3.0
|
2024-02-05 17:08:05 +08:00 |
|
wangmm0220
|
a656d75ca7
|
opti:consume data excluded from some source
|
2024-02-05 17:07:50 +08:00 |
|
wangmm0220
|
d369289ea2
|
fix:[TD-28514] memory leak
|
2024-02-01 16:34:05 +08:00 |
|
wangmm0220
|
bd2bef2428
|
fix:add test case
|
2024-01-26 15:05:31 +08:00 |
|
wangmm0220
|
2798ff824c
|
feat:[TD-28247]add grant for subscribe and stream
|
2024-01-25 16:07:09 +08:00 |
|
wangmm0220
|
1b85adaa3a
|
opti:[TD-28118] raw block data for tmq
|
2024-01-18 14:17:08 +08:00 |
|
wangmm0220
|
d5d1dd9127
|
opti:[TD-28118] raw block data for tmq
|
2024-01-17 20:08:26 +08:00 |
|
wangmm0220
|
d3659db2ff
|
fix:[TD-28202]move tq timer to write thread in mnode
|
2024-01-11 19:22:54 +08:00 |
|
wangmm0220
|
53ce344b36
|
fix:set error msg if build consumer error
|
2023-12-28 17:09:52 +08:00 |
|
wangmm0220
|
e1eda752e7
|
fix:[TS-4242] tmq status is always RECOVER
|
2023-11-23 20:44:10 +08:00 |
yihaoDeng
|
55e66eac3c
|
fix:print log if assert & check epoch when update epoch
|
2023-10-31 20:47:08 +08:00 |
|
wangmm0220
|
e92460105c
|
fix:print log if assert & check epoch when update epoch
|
2023-10-31 15:36:32 +08:00 |
|
wangmm0220
|
770c88200f
|
fix:print log if assert & check epoch when update epoch
|
2023-10-30 09:19:31 +08:00 |
|
wangmm0220
|
473142fab7
|
fix:conflicts from 3.0
|
2023-10-16 11:35:56 +08:00 |
Haojun Liao
|
cdd480d186
|
Merge pull request #23249 from taosdata/feat/TD-26052
fix:core dump if tmq is null
|
2023-10-13 16:50:48 +08:00 |
|
wangmm0220
|
9cfb15d4f4
|
fix:core dump if tmq is null
|
2023-10-13 14:04:00 +08:00 |
|
Haojun Liao
|
eb4449999f
|
other: merge 3.0
|
2023-10-12 10:33:48 +08:00 |
|
wangmm0220
|
33045e63ae
|
feat:[TD-26056] add replay logic
|
2023-10-09 17:35:40 +08:00 |
|
wangmm0220
|
5f7b6f19ba
|
feat:[TD-26056] add replay logic
|
2023-10-08 19:05:59 +08:00 |
|
wangmm0220
|
3f2d890560
|
feat:[TD-26056] add replay logic
|
2023-10-08 16:06:15 +08:00 |
|
wangmm0220
|
9c470e9297
|
opti:set default offset to latest in subscription & return error if use snapshot when consume column
|
2023-10-07 15:25:24 +08:00 |
|
Haojun Liao
|
68c329e1f7
|
Merge pull request #23015 from taosdata/mark/tmq-3.0
fix:add interface tmq_get_connect to get TAOS from tmq
|
2023-09-22 14:02:19 +08:00 |
|
wangmm0220
|
63a6aacc18
|
fix:add interface tmq_get_connect to get TAOS from tmq
|
2023-09-22 11:44:37 +08:00 |
|
wangmm0220
|
70b5509217
|
fix:enable split if there are topics
|
2023-09-21 18:16:05 +08:00 |
|
wangmm0220
|
06afd0bd33
|
fix:add interface tmq_get_connect to get TAOS from tmq
|
2023-09-21 15:13:38 +08:00 |
|
wangmm0220
|
7869b693f2
|
add test case for tmq in vnode transform & fix core in race condition for pTq->pExecStore
|
2023-09-18 14:09:28 +08:00 |
|
wangmm0220
|
ef81299494
|
fix:heap use after free
|
2023-09-14 13:41:14 +08:00 |
|
wangmm0220
|
a833d5d769
|
fix:need update epset if unsubscribe topic and topicNumGet is 0 at the same time
|
2023-09-14 10:39:22 +08:00 |
|
wangmm0220
|
f729150497
|
fix:opti poll callbak logic & send epoch as -1 to get epset if vnode transformed
|
2023-09-13 18:32:45 +08:00 |
|
wangmm0220
|
d707f69a6c
|
opti:ask ep logic in tmq
|
2023-09-13 09:52:24 +08:00 |
|
wangmm0220
|
f4ec83025d
|
opti:optimize code logic & fix python test case error
|
2023-09-06 19:46:17 +08:00 |
|
wangmm0220
|
629de12bb1
|
fix:do not return error if commit nothing
|
2023-09-06 18:29:28 +08:00 |
|
wangmm0220
|
cc62961337
|
fix:heap use after free of pParamSet since the first commitCb is called before send another commit message
|
2023-09-06 14:45:07 +08:00 |
|
wangmm0220
|
897fd5b8b5
|
fix:tmq close error because of same committed offset
|
2023-09-06 10:15:41 +08:00 |
|
wangmm0220
|
53c4f4a147
|
opti:commit logic
|
2023-09-05 10:35:05 +08:00 |
|
wangmm0220
|
9a2da3adee
|
fix:set vg status idle if reveive poll callback
|
2023-09-04 18:31:07 +08:00 |