From a6930d05ab2e02769f497c65d1b760f688eafdc9 Mon Sep 17 00:00:00 2001
From: wzl12356 <wzlsuccess@163.com>
Date: Thu, 31 Mar 2022 21:21:30 +0800
Subject: [PATCH] kafka: fix meta_callback set uninit state

---
 src/client/WFKafkaClient.cc | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/client/WFKafkaClient.cc b/src/client/WFKafkaClient.cc
index f30437ae..8de934d3 100644
--- a/src/client/WFKafkaClient.cc
+++ b/src/client/WFKafkaClient.cc
@@ -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;