|
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.