rd_kafka_topic_partition_t Struct Reference

Topic+Partition place holder. More...

#include <rdkafka.h>

Data Fields
char *	topic
int32_t	partition
int64_t	offset
void *	metadata
size_t	metadata_size
void *	opaque
rd_kafka_resp_err_t	err
void *	_private

Detailed Description

Topic+Partition place holder.

Generic place holder for a Topic+Partition and its related information used for multiple purposes:

• consumer offset (see rd_kafka_commit(), et.al.)
• group rebalancing callback (rd_kafka_conf_set_rebalance_cb())
• offset commit result callback (rd_kafka_conf_set_offset_commit_cb()) Generic place holder for a specific Topic+Partition.

See also

rd_kafka_topic_partition_list_new()

Field Documentation

char* rd_kafka_topic_partition_t::topic

Topic name

int32_t rd_kafka_topic_partition_t::partition

Partition

int64_t rd_kafka_topic_partition_t::offset

Offset

void* rd_kafka_topic_partition_t::metadata

Metadata

size_t rd_kafka_topic_partition_t::metadata_size

Metadata size

void* rd_kafka_topic_partition_t::opaque

Opaque value for application use

rd_kafka_resp_err_t rd_kafka_topic_partition_t::err

Error code, depending on use.

void* rd_kafka_topic_partition_t::_private

INTERNAL USE ONLY, INITIALIZE TO ZERO, DO NOT TOUCH

---

The documentation for this struct was generated from the following file:

• src/rdkafka.h