Adbase
Adinf C++ base library V2
|
This is the complete list of members for adbase::kafka::Producer, including all inherited members.
deleteThread(std::thread *t) | adbase::kafka::Producer | static |
deliveredCallback(rd_kafka_resp_err_t err, uint64_t ackCode) | adbase::kafka::Producer | |
logger(const rd_kafka_t *rk, int level, const char *fac, const char *buf) | adbase::kafka::Producer | static |
Producer(const std::string &brokerList, int queueLen, const std::string &debug) | adbase::kafka::Producer | |
setAckHandler(const MessageAckCallback &ackHandler) | adbase::kafka::Producer | inline |
setErrorHandler(const MessageErrorCallback &errorHandler) | adbase::kafka::Producer | inline |
setSendHandler(const MessageSendCallback &sendHandler) | adbase::kafka::Producer | inline |
start() | adbase::kafka::Producer | |
stop() | adbase::kafka::Producer | |
threadFunc(void *data) | adbase::kafka::Producer | |
~Producer() | adbase::kafka::Producer |