Metadata: Partition information.
More...
#include <rdkafkacpp.h>
|
virtual int32_t | id () const =0 |
|
virtual ErrorCode | err () const =0 |
|
virtual int32_t | leader () const =0 |
|
virtual const std::vector< int32_t > * | replicas () const =0 |
|
virtual const std::vector< int32_t > * | isrs () const =0 |
|
Metadata: Partition information.
◆ id()
virtual int32_t RdKafka::PartitionMetadata::id |
( |
| ) |
const |
|
pure virtual |
◆ err()
virtual ErrorCode RdKafka::PartitionMetadata::err |
( |
| ) |
const |
|
pure virtual |
- Returns
- Partition error reported by broker
◆ leader()
virtual int32_t RdKafka::PartitionMetadata::leader |
( |
| ) |
const |
|
pure virtual |
- Returns
- Leader broker (id) for partition
◆ replicas()
virtual const std::vector<int32_t>* RdKafka::PartitionMetadata::replicas |
( |
| ) |
const |
|
pure virtual |
◆ isrs()
virtual const std::vector<int32_t>* RdKafka::PartitionMetadata::isrs |
( |
| ) |
const |
|
pure virtual |
- Returns
- In-Sync-Replica brokers
- Warning
- The broker may return a cached/outdated list of ISRs.
The documentation for this class was generated from the following file: