librdkafka
The Apache Kafka C/C++ client library
|
#include <rdkafkacpp.h>
Public Member Functions | |
virtual std::string | errstr () const =0 |
Accessor functions*. More... | |
virtual ErrorCode | err () const =0 |
virtual Topic * | topic () const =0 |
virtual std::string | topic_name () const =0 |
virtual int32_t | partition () const =0 |
virtual void * | payload () const =0 |
virtual size_t | len () const =0 |
virtual const std::string * | key () const =0 |
virtual const void * | key_pointer () const =0 |
virtual size_t | key_len () const =0 |
virtual int64_t | offset () const =0 |
virtual MessageTimestamp | timestamp () const =0 |
virtual void * | msg_opaque () const =0 |
Message object.
This object represents either a single consumed or produced message, or an event (err()
is set).
An application must check RdKafka::Message::err() to see if the object is a proper message (error is RdKafka::ERR_NO_ERROR) or a an error event.
|
pure virtual |
Accessor functions*.
|
pure virtual |
|
pure virtual |
|
pure virtual |
|
pure virtual |
|
pure virtual |
|
pure virtual |
|
pure virtual |
|
pure virtual |
|
pure virtual |
|
pure virtual |
|
pure virtual |
|
pure virtual |
msg_opaque
as provided to RdKafka::Producer::produce()