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

fix:add excluded msg for meta in tmq

This commit is contained in:
wangmm0220 2024-02-22 11:32:45 +08:00
parent 6e13e4aa63
commit c22360a529
2 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/system-test/7-tmq/tmq_taosx.py
View File

@ -323,7 +323,7 @@ class TDTestCase:
tdSql.query("select * from st") tdSql.query("select * from st")
tdSql.checkRows(8) tdSql.checkRows(8)
tdSql.execute(f'create topic topic_excluded with meta as database d1') tdSql.execute(f'create topic topic_all with meta as database d1')
consumer_dict = { consumer_dict = {
"group.id": "g1", "group.id": "g1",
"td.connect.user": "root", "td.connect.user": "root",
@ -333,7 +333,7 @@ class TDTestCase:
consumer = Consumer(consumer_dict) consumer = Consumer(consumer_dict)
try: try:
consumer.subscribe(["topic_excluded"]) consumer.subscribe(["topic_all"])
except TmqError: except TmqError:
tdLog.exit(f"subscribe error") tdLog.exit(f"subscribe error")

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

@ -20,6 +20,7 @@
#include <time.h> #include <time.h>
#include "taos.h" #include "taos.h"
#include "types.h" #include "types.h"
#include "tmsg.h"
static int running = 1; static int running = 1;
TdFilePtr g_fp = NULL; TdFilePtr g_fp = NULL;
@ -966,7 +967,14 @@ void testConsumeExcluded(int topic_type){
tmq_raw_data raw = {0}; tmq_raw_data raw = {0};
tmq_get_raw(msg, &raw); tmq_get_raw(msg, &raw);
if(topic_type == 1){ if(topic_type == 1){
assert(raw.raw_type != 2 && raw.raw_type != 4); assert(raw.raw_type != 2 && raw.raw_type != 4 &&
raw.raw_type != TDMT_VND_CREATE_STB &&
raw.raw_type != TDMT_VND_ALTER_STB &&
raw.raw_type != TDMT_VND_CREATE_TABLE &&
raw.raw_type != TDMT_VND_ALTER_TABLE &&
raw.raw_type != TDMT_VND_DELETE);
assert(raw.raw_type == TDMT_VND_DROP_STB ||
raw.raw_type == TDMT_VND_DROP_TABLE);
}else if(topic_type == 2){ }else if(topic_type == 2){
assert(0); assert(0);
} }