kafka_client.h File Reference

Go to the source code of this file.

Data Structures
class	NvDsKafkaSendCompl
class	NvDsKafkaSyncSendCompl
class	NvDsKafkaAsyncSendCompl
struct	consumer_thread_info
struct	consumer_instance_t
struct	producer_instance_t
struct	NvDsKafkaClientHandle

Macros
#define	MAX_FIELD_LEN   1024
#define	MAX_TOPIC_LEN   255
#define	NVDS_KAFKA_LOG_CAT   "DSLOG:NVDS_KAFKA_PROTO"

Functions
void *	nvds_kafka_client_init (NvDsKafkaClientHandle *kh)
NvDsMsgApiErrorType	nvds_kafka_producer_launch (void *kh, rd_kafka_conf_t *conf)
NvDsMsgApiErrorType	nvds_kafka_client_send (void *kh, const uint8_t *payload, int len, char *topic, int sync, void *ctx, nvds_msgapi_send_cb_t cb, char *key, int keylen)
NvDsMsgApiErrorType	nvds_kafka_client_setconf (rd_kafka_conf_t *conf, char *key, char *val)
void	nvds_kafka_client_poll (void *kv)
void	nvds_kafka_client_finish (void *kv)

Macro Definition Documentation

MAX_FIELD_LEN

#define MAX_FIELD_LEN   1024

Definition at line 21 of file kafka_client.h.

MAX_TOPIC_LEN

#define MAX_TOPIC_LEN   255

Definition at line 22 of file kafka_client.h.

NVDS_KAFKA_LOG_CAT

#define NVDS_KAFKA_LOG_CAT   "DSLOG:NVDS_KAFKA_PROTO"

Definition at line 23 of file kafka_client.h.

Function Documentation

nvds_kafka_client_finish()

void nvds_kafka_client_finish

(

void *

kv

)

nvds_kafka_client_init()

void* nvds_kafka_client_init

(

NvDsKafkaClientHandle *

kh

)

nvds_kafka_client_poll()

void nvds_kafka_client_poll

(

void *

kv

)

nvds_kafka_client_send()

NvDsMsgApiErrorType nvds_kafka_client_send	(	void *	kh,
		const uint8_t *	payload,
		int	len,
		char *	topic,
		int	sync,
		void *	ctx,
		nvds_msgapi_send_cb_t	cb,
		char *	key,
		int	keylen
	)

nvds_kafka_client_setconf()

NvDsMsgApiErrorType nvds_kafka_client_setconf	(	rd_kafka_conf_t *	conf,
		char *	key,
		char *	val
	)

nvds_kafka_producer_launch()

NvDsMsgApiErrorType nvds_kafka_producer_launch	(	void *	kh,
		rd_kafka_conf_t *	conf
	)