Merge pull request #27055 from taosdata/fix/TD-31250

fix:[TD-31250] change poll delay 1s->5s to avoid no data generated by…
This commit is contained in:
dapan1121 2024-08-08 09:21:04 +08:00 committed by GitHub
commit 942f68236a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions

View File

@ -633,7 +633,7 @@ void basic_consume_loop(tmq_t* tmq, tmq_list_t* topics) {
}
int32_t cnt = 0;
while (running) {
TAOS_RES* tmqmessage = tmq_consumer_poll(tmq, 1000);
TAOS_RES* tmqmessage = tmq_consumer_poll(tmq, 5000);
if (tmqmessage) {
cnt++;
msg_process(tmqmessage);