Partition

Undocumented in source.

struct Partition {

int partition;

QueueBuffer* buffer;

Partition* next;

}

Members

Variables

buffer QueueBuffer* buffer;: Undocumented in source.
next Partition* next;: field used to build the partition linked list for each topic for the dynamic fetch/produce request
partition int partition;: Undocumented in source.
queue Queue queue;: Undocumented in source.

Meta

Source

See Implementation

kafkad bundler classes

RequestBundler

structs