Struct NewTopic 

pub struct NewTopic {
    pub name: String,
    pub partitions: i32,
    pub replication_factor: i16,
    pub config: BTreeMap<String, String>,
}

A topic to create.

Fields

name: String

partitions: i32

replication_factor: i16

config: BTreeMap<String, String>

Topic configuration, as the broker names it — retention.ms, cleanup.policy, and so on.

Implementations

impl NewTopic

pub fn new( name: impl Into<String>, partitions: i32, replication_factor: i16, ) -> Self

A topic with broker defaults for everything but its shape.

pub fn with_config( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Trait Implementations

impl Clone for NewTopic

fn clone(&self) -> NewTopic

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NewTopic

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

Formats the value using the given formatter.