1 files changed, 10 insertions, 3 deletions
diff --git a/common/src/tfe_resource.cpp b/common/src/tfe_resource.cpp
index 2a4e73f..3ec83bc 100644
--- a/common/src/tfe_resource.cpp
+++ b/common/src/tfe_resource.cpp
@@ -200,14 +200,21 @@ static tfe_kafka_logger_t *create_kafka_logger(const char *profile, const char *
         return NULL;
     }
 
-    kafka_logger = tfe_kafka_logger_create(enable, nic_name, brokerlist, logger_topic, sasl_username, sasl_passwd, logger);
+    kafka_logger = tfe_kafka_logger_create(enable, nic_name, brokerlist, sasl_username, sasl_passwd, logger);
     if (kafka_logger == NULL)
     {
         TFE_LOG_ERROR(logger, "tfe kafka init failed, error to create kafka logger.");
         return NULL;
     }
-    int ret = tfe_kafka_logger_topic_new(kafka_logger, bucket_topic, logger);
-    if(ret == 0)
+
+	int ret = tfe_kafka_logger_topic_new(kafka_logger, logger_topic, TOPIC_LOGGER, logger);
+    if(ret < 0)
+    {
+        return NULL;
+    }
+	
+    ret = tfe_kafka_logger_topic_new(kafka_logger, bucket_topic, TOPIC_BUCKET, logger);
+    if(ret < 0)
     {
         return NULL;
     }