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;