Topic

Undocumented in source.

struct Topic {

string topic;

Partition*[int] partitions;

Partition* requestPartitionsFront;

Partition* requestPartitionsBack;

bool isInRequest;

size_t partitionsInRequest;

Partition* findPartition(int partition);

}

Members

Functions

findPartition Partition* findPartition(int partition): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

isInRequest bool isInRequest;: false if this topic is not in the linked list, true if it is already added
next Topic* next;: field used to build the topic linked list for the dynamic fetch/produce request
partitions Partition*[int] partitions;: Undocumented in source.
partitionsInRequest size_t partitionsInRequest;: number of partition in the partition linked list for this topic
requestPartitionsBack Partition* requestPartitionsBack;: Undocumented in source.
requestPartitionsFront Partition* requestPartitionsFront;: Undocumented in source.
topic string topic;: Undocumented in source.

Meta

Source

See Implementation

kafkad bundler classes

RequestBundler

structs