diff options
Diffstat (limited to 'common/include')
| -rw-r--r-- | common/include/tfe_kafka_logger.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/common/include/tfe_kafka_logger.h b/common/include/tfe_kafka_logger.h index 82db3d7..0ea0d20 100644 --- a/common/include/tfe_kafka_logger.h +++ b/common/include/tfe_kafka_logger.h @@ -28,12 +28,12 @@ typedef struct tfe_kafka_logger_s char topic_name[TOPIC_MAX][TFE_STRING_MAX]; char broker_list[TFE_STRING_MAX]; - rd_kafka_t *kafka_handle; + rd_kafka_t *kafka_handle[TOPIC_MAX]; 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 *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); +tfe_kafka_logger_t *tfe_kafka_logger_create(int enable, const char *nic_name, const char *brokerlist, void *local_logger); +int tfe_logger_create_kafka_topic(tfe_kafka_logger_t *logger, const char *sasl_username, const char *sasl_passwd, 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); |