TopicPartition

Topic+Partition

This is a generic type to hold a single partition and various information about it.

Is typically used with std::vector<TopicPartition*> to provide a list of partitions for different operations.

struct TopicPartition {

const(char)* topic_;

int partition_;

long offset_;

ErrorCode err_;

void toString(void delegate(const(char)[]) sink);

this(const(char)* topic, int partition);

this(rd_kafka_topic_partition_t* c_part);

int partition();

const(char)[] topic();

long offset();

void offset(long offset);

ErrorCode err();

}

Constructors

this this(const(char)* topic, int partition): Create topic+partition object for \p topic and \p partition.
this this(rd_kafka_topic_partition_t* c_part): Undocumented in source.

Members

Functions

err ErrorCode err(): error code (if applicable)
offset long offset(): offset (if applicable)
offset void offset(long offset): Set offset
partition int partition(): partition id
toString void toString(void delegate(const(char)[]) sink): Undocumented in source. Be warned that the author may not have intended to support it.
topic const(char)[] topic(): topic name

Variables

err_ ErrorCode err_;: Undocumented in source.
offset_ long offset_;: Undocumented in source.
partition_ int partition_;: Undocumented in source.
topic_ const(char)* topic_;: Undocumented in source.

Meta

Source

See Implementation

rdkafkad topic classes

Topic

enums

Offset

structs

TopicPartition