RdKafka::PartitionMetadata Class Reference

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:

• src-cpp/rdkafkacpp.h