librdkafka
The Apache Kafka C/C++ client library
 All Data Structures Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
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

virtual int32_t RdKafka::PartitionMetadata::id ( ) const
pure virtual
Returns
Partition id
virtual ErrorCode RdKafka::PartitionMetadata::err ( ) const
pure virtual
Returns
Partition error reported by broker
virtual int32_t RdKafka::PartitionMetadata::leader ( ) const
pure virtual
Returns
Leader broker (id) for partition
virtual const std::vector<int32_t>* RdKafka::PartitionMetadata::replicas ( ) const
pure virtual
Returns
Replica brokers
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: