From c94eab176be2dd6fb374e74461137b5b6f2feecb Mon Sep 17 00:00:00 2001 From: luwenpeng Date: Tue, 31 Mar 2020 14:44:08 +0800 Subject: [PATCH] =?UTF-8?q?TSG-935=20=E4=BF=AE=E5=A4=8D=20bug=EF=BC=8C?= =?UTF-8?q?=E4=BF=AE=E6=94=B9=20kafka=20logger=20=E8=BF=94=E5=9B=9E?= =?UTF-8?q?=E5=80=BC=E7=9A=84=E5=88=A4=E6=96=AD=E6=9D=A1=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- plugin/business/pangu-http/src/pangu_logger.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugin/business/pangu-http/src/pangu_logger.cpp b/plugin/business/pangu-http/src/pangu_logger.cpp index 86dd01f..df36e55 100644 --- a/plugin/business/pangu-http/src/pangu_logger.cpp +++ b/plugin/business/pangu-http/src/pangu_logger.cpp @@ -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;