diff --git a/utils/test/c/tmq_td32471.c b/utils/test/c/tmq_td32471.c
index bf14e3f61b..80f93541f9 100644
--- 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)