librdkafka
The Apache Kafka C/C++ client library
|
Topic+Partition. More...
#include <rdkafkacpp.h>
Public Member Functions | |
virtual const std::string & | topic () const =0 |
virtual int | partition ()=0 |
virtual int64_t | offset ()=0 |
virtual void | set_offset (int64_t offset)=0 |
Set offset. | |
virtual ErrorCode | err ()=0 |
Static Public Member Functions | |
static TopicPartition * | create (const std::string &topic, int partition) |
Topic+Partition.
This is a generic type to hold a single partition and various information about it.
Is typically used with std::vector<RdKafka::TopicPartition*> to provide a list of partitions for different operations.
|
static |
Create topic+partition object for topic
and partition
.
Use delete
to deconstruct.
|
pure virtual |
|
pure virtual |
|
pure virtual |
|
pure virtual |