23typedef struct kafka_ctx * kafka_ctx_t;
30void kafka_ctx_destroy(kafka_ctx_t *ctx);
40kafka_ctx_t kafka_create_consumer(
const char *addr,
int timeout);
50kafka_ctx_t kafka_create_producer(
const char *addr,
int timeout);
62nmsg_res kafka_read_start(kafka_ctx_t ctx, uint8_t **buf,
size_t *len);
71nmsg_res kafka_read_finish(kafka_ctx_t ctx);
89 const uint8_t *key,
size_t key_len,
90 uint8_t *buf,
size_t buf_len);
97void kafka_stop(kafka_ctx_t ctx);
104void kafka_flush(kafka_ctx_t ctx);