adbase::kafka Namespace Reference

Namespaces
	detail

Classes
class	Consumer
struct	KafkaContext
class	Producer

Typedefs
typedef std::function< bool(const std::string &topicName, int partId, uint64_t offset, const Buffer &message)>	ConsumerMessageCallback
typedef std::function< void(Consumer *consumer, const std::string &stats)>	ConsumerStatCallback
typedef std::function< bool(std::string &topicName, int *partId, Buffer &message, uint64_t *ackCode)>	MessageSendCallback
typedef std::function< void(uint64_t ackCode)>	MessageAckCallback
typedef std::function< void(uint64_t ackCode)>	MessageErrorCallback
typedef struct adbase::kafka::KafkaContext	KafkaContext

Typedef Documentation

typedef std::function<bool (const std::string& topicName, int partId, uint64_t offset, const Buffer& message)> adbase::kafka::ConsumerMessageCallback

Definition at line 22 of file Consumer.hpp.

typedef std::function<void (Consumer* consumer, const std::string& stats)> adbase::kafka::ConsumerStatCallback

Definition at line 25 of file Consumer.hpp.

typedef struct adbase::kafka::KafkaContext adbase::kafka::KafkaContext

typedef std::function<void (uint64_t ackCode)> adbase::kafka::MessageAckCallback

Definition at line 29 of file Producer.hpp.

typedef std::function<void (uint64_t ackCode)> adbase::kafka::MessageErrorCallback

Definition at line 30 of file Producer.hpp.

typedef std::function<bool (std::string& topicName, int* partId, Buffer& message, uint64_t* ackCode)> adbase::kafka::MessageSendCallback

Definition at line 26 of file Producer.hpp.