fix: remove waitting for empty block & optimize poll logic

2025-03-04 19:12:28 +08:00 · 2025-03-04 19:12:28 +08:00 · 9a3d6e3fb3
parent 08601c5dc9
commit 9a3d6e3fb3
1 changed files with 1 additions and 1 deletions
--- a/utils/test/c/tmq_td32471.c
+++ b/utils/test/c/tmq_td32471.c
@ -76,7 +76,7 @@ void basic_consume_loop(tmq_t* tmq, tmq_list_t* topics) {
  taosSsleep(5);
  TAOS_RES* tmqmessage = tmq_consumer_poll(tmq, 1000);
  ASSERT(tmqmessage == NULL);
-  ASSERT(taos_errno(NULL) == TSDB_CODE_TMQ_CONSUMER_MISMATCH);
+  ASSERT(taos_errno(NULL) == TSDB_CODE_MND_CONSUMER_NOT_EXIST);

  code = tmq_consumer_close(tmq);
  if (code)