Struct MetadataRequest 

pub struct MetadataRequest {
    pub topics: Option<Vec<MetadataRequestTopic>>,
    pub allow_auto_topic_creation: Option<Boolean>,
}

Fields

topics: Option<Vec<MetadataRequestTopic>>

The topics to fetch metadata for

Requests data for all topics if None

allow_auto_topic_creation: Option<Boolean>

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.

Added in version 4

Trait Implementations

impl Debug for MetadataRequest

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

Formats the value using the given formatter.

impl RequestBody for MetadataRequest

const API_VERSION_RANGE: ApiVersionRange

At the time of writing this is the same subset supported by rdkafka

const API_KEY: ApiKey = ApiKey::Metadata

Kafka API key.

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion

The first version of the messages (not of the header) that uses tagged fields, if any.

type ResponseBody = MetadataResponse

The response type that will follow when issuing this request.

const FIRST_TAGGED_FIELD_IN_RESPONSE_VERSION: ApiVersion = Self::FIRST_TAGGED_FIELD_IN_REQUEST_VERSION

Normally the same as FIRST_TAGGED_FIELD_IN_REQUEST_VERSION but there are some special snowflakes.

impl<W> WriteVersionedType<W> for MetadataRequest

where W: Write,

fn write_versioned( &self, writer: &mut W, version: ApiVersion, ) -> Result<(), WriteVersionedError>