diff options
| author | luwenpeng <[email protected]> | 2020-03-31 14:44:08 +0800 |
|---|---|---|
| committer | luwenpeng <[email protected]> | 2020-04-01 13:43:57 +0800 |
| commit | c94eab176be2dd6fb374e74461137b5b6f2feecb (patch) | |
| tree | 390278b482ca264a86f92fd867fdeb9f837369ef | |
| parent | b18cc3928cbf20eee0859ab59fdd788074850520 (diff) | |
TSG-935 修复 bug，修改 kafka logger 返回值的判断条件
| -rw-r--r-- | plugin/business/pangu-http/src/pangu_logger.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
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; |