diff options
Diffstat (limited to 'common/include/tfe_kafka_logger.h')
| -rw-r--r-- | common/include/tfe_kafka_logger.h | 7 |
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); |