Add Kafka Error strings

This commit is contained in:
XieHan
2021-07-06 17:02:31 +08:00
parent a113439226
commit d4c3ff3d32
+27
View File
@@ -740,6 +740,33 @@ static inline const char *__get_task_error_string(int error)
case WFT_ERR_MYSQL_SSL_NOT_SUPPORTED:
return "MySQL SSL Not Supported";
case WFT_ERR_KAFKA_PARSE_RESPONSE_FAILED:
return "Kafka parse response failed";
case WFT_ERR_KAFKA_PRODUCE_FAILED:
return "Kafka produce api failed";
case WFT_ERR_KAFKA_FETCH_FAILED:
return "Kafka fetch api failed";
case WFT_ERR_KAFKA_CGROUP_FAILED:
return "Kafka cgroup failed";
case WFT_ERR_KAFKA_COMMIT_FAILED:
return "Kafka commit api failed";
case WFT_ERR_KAFKA_META_FAILED:
return "Kafka meta api failed";
case WFT_ERR_KAFKA_LEAVEGROUP_FAILED:
return "Kafka leavegroup failed";
case WFT_ERR_KAFKA_API_UNKNOWN:
return "Kafka api type unknown";
case WFT_ERR_KAFKA_VERSION_DISALLOWED:
return "Kafka broker version not supported";
default:
break;
}