From 5ec0fd41b39cb10eecb66858eae19be419cb3c43 Mon Sep 17 00:00:00 2001 From: henryw2019 <34269011+henryw2019@users.noreply.github.com> Date: Thu, 11 Aug 2022 10:06:58 +0800 Subject: [PATCH] Update WFGlobal.cc add some kafka error. --- src/manager/WFGlobal.cc | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/src/manager/WFGlobal.cc b/src/manager/WFGlobal.cc index bbebdeaf..e9275564 100644 --- a/src/manager/WFGlobal.cc +++ b/src/manager/WFGlobal.cc @@ -825,6 +825,18 @@ static inline const char *__get_task_error_string(int error) case WFT_ERR_KAFKA_VERSION_DISALLOWED: return "Kafka broker version not supported"; + case WFT_ERR_KAFKA_SASL_DISALLOWED: + return "Kafka sasl didisallowed"; + + case WFT_ERR_KAFKA_ARRANGE_FAILED: + return "Kafka arrange failed"; + + case WFT_ERR_KAFKA_LIST_OFFSETS_FAILED: + return "Kafka list offsets failed"; + + case WFT_ERR_KAFKA_CGROUP_ASSIGN_FAILED: + return "Kafka cgroup assign failed"; + case WFT_ERR_CONSUL_API_UNKNOWN: return "Consul api type unknown";