Packages

erlkaf

2.1.0
2.2.1 2.2.0 2.1.9 2.1.8 2.1.7 2.1.6 2.1.5 2.1.4 2.1.3 2.1.2 2.1.1 2.1.0 2.0.9 2.0.8 2.0.7 2.0.6 2.0.5 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.2.0 1.1.9 1.1.8 1.1.7 1.1.6 1.1.5 1.1.4 1.1.3

erlkaf - Erlang Kafka library based on librdkafka

HexDocs

Current section

Files

Jump to
Readme
30 Versions
3 Dependencies
Dependants
Files
Activity
erlkaf c_src erlkaf_message.h
Raw

c_src/erlkaf_message.h 

#ifndef C_SRC_ERLKAF_MESSAGE_H_

#define C_SRC_ERLKAF_MESSAGE_H_



#include "erlkaf_nif.h"



typedef struct rd_kafka_message_s rd_kafka_message_t;



ERL_NIF_TERM make_message_nif(ErlNifEnv* env, ERL_NIF_TERM topic, ERL_NIF_TERM partition, const rd_kafka_message_t* msg);

ERL_NIF_TERM make_message_nif(ErlNifEnv* env, const rd_kafka_message_t* msg);



#endif  // C_SRC_ERLKAF_MESSAGE_H_