xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add ci

This commit is contained in:
54liuyao 2024-05-28 19:33:38 +08:00
parent a2255ca355
commit 2cf657c767
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
utils/test/c/tmq_taosx_ci.c
View File

@ -33,6 +33,7 @@ typedef struct {
int srcVgroups; int srcVgroups;
int dstVgroups; int dstVgroups;
char dir[256]; char dir[256];
bool btMeta;
} Config; } Config;
Config g_conf = {0}; Config g_conf = {0};
@ -600,6 +601,10 @@ tmq_t* build_consumer() {
tmq_conf_set(conf, "experimental.snapshot.enable", "true"); tmq_conf_set(conf, "experimental.snapshot.enable", "true");
} }
if (g_conf.btMeta) {
tmq_conf_set(conf, "msg.enable.batchmeta", "true");
}
tmq_conf_set_auto_commit_cb(conf, tmq_commit_cb_print, NULL); tmq_conf_set_auto_commit_cb(conf, tmq_commit_cb_print, NULL);
tmq_t* tmq = tmq_consumer_new(conf, NULL, 0); tmq_t* tmq = tmq_consumer_new(conf, NULL, 0);
assert(tmq); assert(tmq);
@ -1184,6 +1189,8 @@ int main(int argc, char* argv[]) {
g_conf.subTable = true; g_conf.subTable = true;
} else if (strcmp(argv[i], "-onlymeta") == 0) { } else if (strcmp(argv[i], "-onlymeta") == 0) {
g_conf.meta = 1; g_conf.meta = 1;
} else if (strcmp(argv[i], "-bt") == 0) {
g_conf.btMeta = true;
} }
} }