|
NVIDIA DeepStream SDK API Reference
|
7.0 Release
|
Go to the documentation of this file.
22 #define MAX_FIELD_LEN 1024
23 #define MAX_TOPIC_LEN 255 //maximum topic length supported by kafka is 255
24 #define NVDS_KAFKA_LOG_CAT "DSLOG:NVDS_KAFKA_PROTO"
void nvds_kafka_client_finish(void *kv)
NvDsMsgApiErrorType nvds_kafka_producer_launch(void *kh, rd_kafka_conf_t *conf)
producer_instance_t p_instance
NvDsMsgApiErrorType
Defines completion codes for operations in the messaging API.
NvDsMsgApiErrorType nvds_kafka_client_setconf(rd_kafka_conf_t *conf, char *key, char *val)
nvds_msgapi_subscribe_request_cb_t subscribe_req_cb
void nvds_kafka_client_poll(void *kv)
consumer_instance_t c_instance
consumer_thread_info cinfo
void(* nvds_msgapi_send_cb_t)(void *user_ptr, NvDsMsgApiErrorType completion_flag)
Type definition for a "send" callback.
void * nvds_kafka_client_init(NvDsKafkaClientHandle *kh)
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)
void(* nvds_msgapi_subscribe_request_cb_t)(NvDsMsgApiErrorType flag, void *msg, int msg_len, char *topic, void *user_ptr)
Type definition for callback registered during subscribe.