Struct rdkafka::admin::NewTopic

pub struct NewTopic<'a> {
    pub name: &'a str,
    pub num_partitions: i32,
    pub replication: TopicReplication<'a>,
    pub config: Vec<(&'a str, &'a str)>,
}

Configuration for a CreateTopic operation.

Fields

name: &'a str

The name of the new topic.

num_partitions: i32

The initial number of partitions.

replication: TopicReplication<'a>

The initial replication configuration.

config: Vec<(&'a str, &'a str)>

The initial configuration parameters for the topic.

Implementations

impl<'a> NewTopic<'a>

pub fn new( name: &'a str, num_partitions: i32, replication: TopicReplication<'a>, ) -> NewTopic<'a>

Creates a new NewTopic.

pub fn set(self, key: &'a str, value: &'a str) -> NewTopic<'a>

Sets a new parameter in the initial topic configuration.

Trait Implementations

impl<'a> Debug for NewTopic<'a>

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

Formats the value using the given formatter.