This is the complete list of members for adbase::kafka::Consumer, including all inherited members.

Consumer(const std::string &topicName, const std::string &groupId, const std::string &brokerList)	adbase::kafka::Consumer
deleteThread(std::thread *t)	adbase::kafka::Consumer	static
getGroupId()	adbase::kafka::Consumer	inline
getTopicName()	adbase::kafka::Consumer	inline
logger(const rd_kafka_t rk, int level, const char fac, const char *buf)	adbase::kafka::Consumer	static
rebalanceCallback(rd_kafka_t rk, rd_kafka_resp_err_t err, rd_kafka_topic_partition_list_t partitions, void *opaque)	adbase::kafka::Consumer	static
setConsumeTimeout(int consumerTimeout)	adbase::kafka::Consumer	inline
setIsNewConsumer(bool isNewConsumer)	adbase::kafka::Consumer	inline
setKafkaCommitInterval(const std::string &commitInterval)	adbase::kafka::Consumer	inline
setKafkaDebug(const std::string &debug)	adbase::kafka::Consumer	inline
setKafkaQueuedMaxSize(const std::string &queueMaxSize)	adbase::kafka::Consumer	inline
setKafkaQueuedMinMessages(const std::string &queueMinMessages)	adbase::kafka::Consumer	inline
setKafkaStatInterval(const std::string &statInterval)	adbase::kafka::Consumer	inline
setMessageHandler(const ConsumerMessageCallback &messageHandler)	adbase::kafka::Consumer	inline
setOffsetReset(const std::string &offsetReset)	adbase::kafka::Consumer	inline
setOffsetStoreMethod(const std::string &method)	adbase::kafka::Consumer	inline
setOffsetStorePath(const std::string &path)	adbase::kafka::Consumer	inline
setStatCallback(const ConsumerStatCallback &statHandler)	adbase::kafka::Consumer	inline
start()	adbase::kafka::Consumer
statCallback(Consumer *consumer, const std::string &stat)	adbase::kafka::Consumer
statsCallback(rd_kafka_t rk, char json, size_t jsonLen, void *opaque)	adbase::kafka::Consumer	static
stop()	adbase::kafka::Consumer
threadFunc(void *data)	adbase::kafka::Consumer
~Consumer()	adbase::kafka::Consumer