Struct NewTopic 

pub struct NewTopic {
    pub name: String,
    pub num_partitions: i32,
    pub replication_factor: i16,
    pub configs: BTreeMap<String, String>,
}

New Topic.

Fields

name: String

Name returned by Kafka.

num_partitions: i32

Num Partitions.

replication_factor: i16

Replication Factor.

configs: BTreeMap<String, String>

Topic-level configuration entries.

Implementations

impl NewTopic

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

Creates a new value.

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

Sets config and returns the updated value.

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.