Struct kafka_protocol::messages::metadata_request::MetadataRequestBuilder

pub struct MetadataRequestBuilder { /* private fields */ }

Builder for MetadataRequest.

Implementations

impl MetadataRequestBuilder

pub fn topics(&mut self, value: Option<Vec<MetadataRequestTopic>>) -> &mut Self

The topics to fetch metadata for.

Supported API versions: 0-12

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

If this is true, the broker may auto-create topics that we requested which do not already exist, if it is configured to do so.

Supported API versions: 4-12

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

Whether to include cluster authorized operations.

Supported API versions: 8-10

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

Whether to include topic authorized operations.

Supported API versions: 8-12

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

Other tagged fields

pub fn build(&self) -> Result<MetadataRequest, MetadataRequestBuilderError>

Builds a new MetadataRequest.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for MetadataRequestBuilder

fn clone(&self) -> MetadataRequestBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for MetadataRequestBuilder

fn default() -> Self

Returns the “default value” for a type.