Modern C++ Kafka API
|
A key/value pair to be sent to Kafka. More...
#include <ProducerRecord.h>
Public Types | |
using | Id = std::uint64_t |
Public Member Functions | |
ProducerRecord (Topic topic, Partition partition, const Key &key, const Value &value) | |
ProducerRecord (const Topic &topic, Partition partition, const Key &key, const Value &value, Id id) | |
ProducerRecord (const Topic &topic, const Key &key, const Value &value) | |
ProducerRecord (const Topic &topic, const Key &key, const Value &value, Id id) | |
const Topic & | topic () const |
The topic this record is being sent to. | |
Partition | partition () const |
The partition to which the record will be sent (or UNKNOWN_PARTITION if no partition was specified). | |
Key | key () const |
The key (or null if no key is specified). | |
Value | value () const |
The value. | |
Optional< Id > | id () const |
The id to identify the message (consistent with Producer::Metadata::recordId() ). | |
const Headers & | headers () const |
The headers. | |
Headers & | headers () |
The headers. More... | |
void | setPartition (Partition partition) |
Set the partition. | |
void | setKey (const Key &key) |
Set the key. | |
void | setValue (const Value &value) |
Set the value. | |
void | setId (Id id) |
Set the record id. | |
std::string | toString () const |
A key/value pair to be sent to Kafka.
This consists of a topic name to which the record is being sent, an optional partition number, and an optional key and value. Note: ProducerRecord
would not take the ownership from the memory block of Value
.
|
inline |
The headers.
Note: Users could set headers with the reference.