librdkafka
The Apache Kafka C/C++ client library
RdKafka::PartitionMetadata Class Referenceabstract

Metadata: Partition information. More...

#include <rdkafkacpp.h>

Public Types

typedef std::vector< int32_t > ReplicasVector
 Replicas.
 
typedef std::vector< int32_t > ISRSVector
 ISRs (In-Sync-Replicas)
 
typedef ReplicasVector::const_iterator ReplicasIterator
 Replicas iterator.
 
typedef ISRSVector::const_iterator ISRSIterator
 ISRs iterator.
 

Public Member Functions

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
 

Detailed Description

Metadata: Partition information.

Member Function Documentation

§ id()

virtual int32_t RdKafka::PartitionMetadata::id ( ) const
pure virtual
Returns
Partition id

§ 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
Returns
Replica brokers

§ 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: