29 lines
418 B
C
29 lines
418 B
C
#ifndef _KAFKA_H
|
|
#define _KAFKA_H
|
|
|
|
#ifdef __cplusplus
|
|
extern "C"
|
|
{
|
|
#endif
|
|
|
|
enum topic_idx
|
|
{
|
|
TOPIC_RULE_HITS,
|
|
|
|
// add more topic here
|
|
|
|
MAX_TOPIC_NUM,
|
|
};
|
|
|
|
struct kafka *kafka_create(const char *profile);
|
|
void kafka_destroy(struct kafka *handle);
|
|
// return 0: if success
|
|
// return -1: if failed
|
|
int kafka_send(struct kafka *handle, enum topic_idx idx, const char *data, int len);
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|
|
|
|
#endif
|