Struct CreateTopicRequest 

pub struct CreateTopicRequest {
    pub name: String_,
    pub num_partitions: Int32,
    pub replication_factor: Int16,
    pub assignments: Vec<CreateTopicAssignment>,
    pub configs: Vec<CreateTopicConfig>,
    pub tagged_fields: Option<TaggedFields>,
}

Fields

name: String_

The topic name

num_partitions: Int32

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.

Note: default partition count requires broker version >= 2.4.0 (KIP-464)

replication_factor: Int16

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.

Note: default replication factor requires broker version >= 2.4.0 (KIP-464)

assignments: Vec<CreateTopicAssignment>

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

configs: Vec<CreateTopicConfig>

The custom topic configurations to set.

tagged_fields: Option<TaggedFields>

The tagged fields.

Added in version 5

Trait Implementations

impl Debug for CreateTopicRequest

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

Formats the value using the given formatter.

impl<W> WriteVersionedType<W> for CreateTopicRequest

where W: Write,

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