GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-20 22:26:59 +08:00
Code Issues Packages Projects Releases Wiki Activity

kafka: fix meta_callback set uninit state

Browse Source
This commit is contained in:
wzl12356
2022-03-31 21:21:30 +08:00
parent 378946f77c
commit a6930d05ab
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client/WFKafkaClient.cc
+5
View File
@@ -595,6 +595,11 @@ void ComplexKafkaTask::kafka_meta_callback(__WFKafkaTask *task)
}
else
{
t->meta_list.rewind();
KafkaMeta *meta;
while ((meta = t->meta_list.get_next()) != NULL)
(*t->client->member->meta_map)[meta->get_topic()] = META_UNINIT;
t->state = WFT_STATE_TASK_ERROR;
t->error = WFT_ERR_KAFKA_META_FAILED;
t->finish = true;