Modern C++ Kafka API
|
The metadata for a record that has been acknowledged by the server. More...
#include <ProducerCommon.h>
Public Types | |
enum class | PersistedStatus { Not , Possibly , Done } |
Public Member Functions | |
RecordMetadata (const RecordMetadata &another) | |
RecordMetadata (const rd_kafka_message_t *rkmsg, Optional< ProducerRecord::Id > recordId) | |
RecordMetadata & | operator= (const RecordMetadata &another) |
std::string | topic () const |
The topic the record was appended to. | |
Partition | partition () const |
The partition the record was sent to. | |
Optional< Offset > | offset () const |
The offset of the record in the topic/partition. | |
Optional< ProducerRecord::Id > | recordId () const |
The recordId could be used to identify the acknowledged message. | |
KeySize | keySize () const |
The size of the key in bytes. | |
ValueSize | valueSize () const |
The size of the value in bytes. | |
Timestamp | timestamp () const |
The timestamp of the record in the topic/partition. | |
PersistedStatus | persistedStatus () const |
The persisted status of the record. | |
std::string | persistedStatusString () const |
std::string | toString () const |
The metadata for a record that has been acknowledged by the server.