优化kafka句柄创建和TOPIC注册v4.8.52-20231219

1 files changed, 3 insertions, 4 deletions

diff --git a/common/include/tfe_kafka_logger.h b/common/include/tfe_kafka_logger.h
index 2bed406..82db3d7 100644
--- a/common/include/tfe_kafka_logger.h
+++ b/common/include/tfe_kafka_logger.h
@@ -13,6 +13,7 @@ enum kafka_topic_type
 {   
     TOPIC_LOGGER,
     TOPIC_BUCKET,
+    TOPIC_MC_CACHE,
     TOPIC_MAX
 };
 
@@ -31,10 +32,8 @@ typedef struct tfe_kafka_logger_s
     rd_kafka_topic_t *kafka_topic[TOPIC_MAX];
 } tfe_kafka_logger_t;
 
-tfe_kafka_logger_t *tfe_kafka_logger_create(int enable, const char *nic_name, const char *brokerlist, const char *topic_name,
-                                       const char *sasl_username, const char *sasl_passwd, void *local_logger);
-
-int tfe_kafka_logger_topic_new(tfe_kafka_logger_t *logger, const char *topic_name, void *local_logger);
+tfe_kafka_logger_t *tfe_kafka_logger_create(int enable, const char *nic_name, const char *brokerlist, const char *sasl_username, const char *sasl_passwd, void *local_logger);
+int tfe_kafka_logger_topic_new(tfe_kafka_logger_t *logger, const char *topic_name, int topic_id, void *local_logger);
 void tfe_kafka_logger_destroy(tfe_kafka_logger_t *logger);
 int tfe_kafka_logger_send(tfe_kafka_logger_t *logger, int topic_id, const char *data, int len);