Struct kafka_protocol::messages::create_topics_request::CreatableTopicBuilder

pub struct CreatableTopicBuilder { /* private fields */ }

Builder for CreatableTopic.

Implementations

impl CreatableTopicBuilder

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

The number of partitions to create in the topic, or -1 if we are either specifying a manual partition assignment or using the default partitions.

Supported API versions: 0-7

pub fn replication_factor(&mut self, value: i16) -> &mut Self

The number of replicas to create for each partition in the topic, or -1 if we are either specifying a manual partition assignment or using the default replication factor.

Supported API versions: 0-7

pub fn assignments(
    &mut self,
    value: IndexMap<i32, CreatableReplicaAssignment>
) -> &mut Self

The manual partition assignment, or the empty array if we are using automatic assignment.

Supported API versions: 0-7

pub fn configs(
    &mut self,
    value: IndexMap<StrBytes, CreateableTopicConfig>
) -> &mut Self

The custom topic configurations to set.

Supported API versions: 0-7

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

Other tagged fields

pub fn build(&self) -> Result<CreatableTopic, CreatableTopicBuilderError>

Builds a new CreatableTopic.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for CreatableTopicBuilder

fn clone(&self) -> CreatableTopicBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for CreatableTopicBuilder

fn default() -> Self

Returns the “default value” for a type.