kafka.h

Go to the documentation of this file.

 
#pragma once
 
#include <common/xroad_xml.h>
#include <stdint.h>
#include <string.h>
 
#ifdef __cplusplus
extern "C"
{
#endif
 
typedef struct kafka_s kafka_t;
 
typedef struct
{
   void* ctx;                                   
   void (*on_connected)(kafka_t*, void*);       
   void (*on_disconnected)(kafka_t*, void*);    
   void (*on_msg)(kafka_t*, xroad_str_t, const void*, size_t, void*); 
} kafka_callback_t;
 
kafka_t* kafka_create(xroad_xml_tag_t cfg, kafka_callback_t cback);
 
void kafka_destroy(kafka_t* k);
 
xroad_errno_t kafka_start(kafka_t* k);
 
xroad_errno_t kafka_stop(kafka_t* k);
 
xroad_errno_t kafka_send(kafka_t* k, xroad_str_t topic, void* data, size_t len);
 
#ifdef __cplusplus
}
#endif