TSG-935 修复 bug,修改 kafka logger 返回值的判断条件

This commit is contained in:
luwenpeng
2020-03-31 14:44:08 +08:00
parent b18cc3928c
commit c94eab176b

View File

@@ -89,7 +89,7 @@ struct pangu_logger* pangu_log_handle_create(const char* profile, const char* s
TFE_LOG_INFO(local_logger, "Pangu kafka topic : %s", topic_name);
instance->kafka_logger = tfe_kafka_logger_create(instance->en_sendlog, nic_name, brokerlist, topic_name, local_logger);
if (instance->kafka_logger)
if (instance->kafka_logger == NULL)
{
TFE_LOG_ERROR(local_logger,"Pangu log init failed, error to create kafka logger.");
goto error_out;