115 commits

Author	SHA1	Message	Date
wangmm0220	9e018e8e58	fix:[TS-5156]add user/fqdn in show consumers	2024-08-09 14:28:58 +08:00
wangmm0220	d5b990e4ed	fix:[TS-5156]add user in show consumers	2024-08-08 16:38:11 +08:00
wangmm0220	ce3d60ed20	feat:[TS-4592]remove lost status for consumer	2024-07-29 23:57:28 +08:00
dmchen	929cb703e7	fix/TD-30989	2024-07-25 09:49:58 +00:00
WANG MINGMING	535755266d	Merge branch '3.0' into opti/TD-31017	2024-07-23 19:44:06 +08:00
wangmm0220	02346072fc	fix:[TD-31017]process return value in mnode for tmq	2024-07-23 16:02:07 +08:00
wangmm0220	862a40afa0	fix:[TD-31017]process return value in mnode for tmq	2024-07-22 17:30:49 +08:00
dmchen	33ee871acf	fix/TD-30989	2024-07-20 01:25:18 +00:00
dapan1121	e527f2fd0b	fix: validate function return value	2024-07-12 15:22:39 +08:00
wangmm0220	b28437aaba	feat:[TS-4592] clear lost status for consumer	2024-07-10 18:42:20 +08:00
wangmm0220	ddcf7c74f7	fix:[TS-5067] check if consumer belong to this cgroup:topic where drop cgroup	2024-06-21 14:11:33 +08:00
wangmm0220	8e2a2414c0	fix:same subtable same partition by leads to same table name in stream	2024-03-28 13:48:46 +08:00
wangmm0220	d0bdb0ce2b	opti:tmq logic	2024-03-13 19:36:00 +08:00
wangmm0220	4dfc531e6c	opti:subscribe logic	2024-03-12 19:42:26 +08:00
wangmm0220	ac9582b24a	fix:[TD-28567] do not add md5 to the end of subtable if create stream by sma	2024-02-19 13:58:58 +08:00
wangmm0220	478e1a67ae	fix:[TD-28590]add logic for consume excluded	2024-02-06 18:14:06 +08:00
Haojun Liao	d4bab8c09b	refactor: do some internal refactor.	2024-01-25 16:53:30 +08:00
Haojun Liao	8a7e38ad15	fix(stream): fix checkpoint failure check.	2024-01-24 13:10:53 +08:00
Haojun Liao	2cc584ff44	fix(stream): fix error in check vgId.	2024-01-22 11:05:42 +08:00
yihaoDeng	83a5e2be4c	stream change ver	2023-08-31 11:42:12 +08:00
yihaoDeng	05ca71d5de	stream change ver	2023-08-31 09:28:43 +08:00
Haojun Liao	f633c7fe2b	other: merge 3.0.	2023-08-10 11:56:30 +08:00
yihaoDeng	6dc93a8dec	add stream ver	2023-08-04 13:52:20 +08:00
Haojun Liao	f4a3567935	other: merge 3.0	2023-07-06 11:24:30 +08:00
Haojun Liao	200575647c	Merge branch '3.0' into refact/fillhistory	2023-07-03 15:16:18 +08:00
dapan1121	3519e9170e	Merge remote-tracking branch 'origin/main' into 3.0	2023-06-29 11:13:45 +08:00
wangmm0220	7d15958509	Merge branch 'main' of https://github.com/taosdata/TDengine into mark/tmq	2023-06-27 18:18:27 +08:00
Yihao Deng	4de7db06f9	Merge branch '3.0' into enh/triggerCheckPoint2	2023-06-27 17:57:14 +08:00
Haojun Liao	3289ad62be	other: merge 3.0	2023-06-27 11:33:40 +08:00
liuyao	e9d3198e05	mem leak	2023-06-25 10:57:10 +08:00
yihaoDeng	fd85a8495a	Merge branch 'dev30' into enh/triggerCheckPoint2	2023-06-17 14:17:21 +08:00
wangmm0220	c5dfe169a6	fix:error	2023-06-16 19:33:03 +08:00
yihaoDeng	5cd35cc18c	refactor checkpoint	2023-06-16 17:28:54 +08:00
yihaoDeng	b0a3a8d619	refactor checkpoint	2023-06-16 17:28:50 +08:00
Haojun Liao	933801269a	fix(stream): fix memory leak and failed to close vnode.	2023-06-16 09:55:11 +08:00
wangmm0220	38dc8e2107	Merge branch 'fix/TS-3540' of https://github.com/taosdata/TDengine into fix/TS-3540	2023-06-15 19:45:15 +08:00
wangmm0220	c243e470c9	fix:null pointer error if restore from file	2023-06-15 19:44:58 +08:00
wangmm0220	e019ed2cc3	fix:conflict	2023-06-15 18:50:44 +08:00
Haojun Liao	f3df37bf28	fix(stream): fix memory leak.	2023-06-15 17:56:58 +08:00
yihaoDeng	a17a8cc192	fix:null pointer error	2023-06-15 16:35:53 +08:00
wangmm0220	a7a518aaed	opti:tmq logic	2023-06-15 15:44:52 +08:00
Haojun Liao	74e0138f72	Merge branch '3.0' into refact/fillhistory	2023-06-15 15:25:00 +08:00
wangmm0220	22776e60d5	fix:control memory size if consumer group is too much	2023-06-15 14:51:04 +08:00
wangmm0220	864236a8dc	fix:conflicts	2023-06-14 12:05:10 +08:00
wangmm0220	c28d7d9bf8	fix:open info log in tmq client & modify parametes in show consumers	2023-06-14 12:01:54 +08:00
wangmm0220	827e84b1a5	fix:memory leak	2023-06-13 17:10:23 +08:00
wangmm0220	8a81278024	fix:load pHandle if necessary wher tq restore	2023-06-13 15:14:11 +08:00
wangmm0220	fb123d8761	fix:conflict from 3.0	2023-06-13 09:47:08 +08:00
wangmm0220	fb59ec4591	feat:move plan msg from vginfo to subscription info	2023-06-13 09:32:54 +08:00
wangmm0220	fe155898fe	fix:modify offset description to string	2023-06-12 16:34:53 +08:00