Struct kafka_protocol::messages::create_partitions_request::CreatePartitionsRequestBuilder

pub struct CreatePartitionsRequestBuilder { /* private fields */ }

Builder for CreatePartitionsRequest.

Implementations

impl CreatePartitionsRequestBuilder

pub fn topics( &mut self, value: IndexMap<TopicName, CreatePartitionsTopic> ) -> &mut Self

Each topic that we want to create new partitions inside.

Supported API versions: 0-3

pub fn timeout_ms(&mut self, value: i32) -> &mut Self

The time in ms to wait for the partitions to be created.

Supported API versions: 0-3

pub fn validate_only(&mut self, value: bool) -> &mut Self

If true, then validate the request, but don’t actually increase the number of partitions.

Supported API versions: 0-3

pub fn unknown_tagged_fields( &mut self, value: BTreeMap<i32, Bytes> ) -> &mut Self

Other tagged fields

pub fn build( &self ) -> Result<CreatePartitionsRequest, CreatePartitionsRequestBuilderError>

Builds a new CreatePartitionsRequest.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for CreatePartitionsRequestBuilder

fn clone(&self) -> CreatePartitionsRequestBuilder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for CreatePartitionsRequestBuilder

fn default() -> Self

Returns the “default value” for a type.