Struct kafka_api::metadata_request::MetadataRequest

pub struct MetadataRequest {
    pub topics: Vec<MetadataRequestTopic>,
    pub allow_auto_topic_creation: bool,
    pub include_cluster_authorized_operations: bool,
    pub include_topic_authorized_operations: bool,
    pub unknown_tagged_fields: Vec<RawTaggedField>,
}

Fields

topics: Vec<MetadataRequestTopic>

The topics to fetch metadata for.

allow_auto_topic_creation: bool

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.

include_cluster_authorized_operations: bool

Whether to include cluster authorized operations.

include_topic_authorized_operations: bool

Whether to include topic authorized operations.

unknown_tagged_fields: Vec<RawTaggedField>

Unknown tagged fields.

Trait Implementations

impl Debug for MetadataRequest

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Decodable for MetadataRequest

fn decode<B: Buf>(buf: &mut B, version: i16) -> Result<Self>

impl Default for MetadataRequest

fn default() -> MetadataRequest

Returns the “default value” for a type.