Current section
Files
Jump to
Current section
Files
c_src/erlkaf_config.h
#ifndef C_SRC_ERLKAF_CONFIG_H_
#define C_SRC_ERLKAF_CONFIG_H_
#include "erl_nif.h"
typedef struct rd_kafka_conf_s rd_kafka_conf_t;
typedef struct rd_kafka_topic_conf_s rd_kafka_topic_conf_t;
enum TargetObject {
Producer = 0,
Consumer,
};
ERL_NIF_TERM parse_topic_config(ErlNifEnv* env, ERL_NIF_TERM list, rd_kafka_topic_conf_t* conf);
ERL_NIF_TERM parse_kafka_config(ErlNifEnv* env, ERL_NIF_TERM list, rd_kafka_conf_t* conf, TargetObject target);
#endif // C_SRC_ERLKAF_CONFIG_H_