Struct NewTopic 

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

Topic definition used with KafkaAdmin::create_topics.

num_partitions and replication_factor must both be positive. Additional topic-level broker configs can be attached with NewTopic::with_config.

use kafkit_client::NewTopic;

admin
    .create_topics([
        NewTopic::new("orders", 6, 3)
            .with_config("cleanup.policy", "delete")
            .with_config("retention.ms", "604800000"),
    ])
    .await?;

Fields

name: String

Topic name to create.

num_partitions: i32

Number of partitions for the new topic.

replication_factor: i16

Number of replicas Kafka should create for each partition.

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 topic definition.

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

Adds a topic-level config entry and returns the updated definition.

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.