Struct NewTopic 

pub struct NewTopic { /* private fields */ }

Definition of one Kafka topic to create.

Implementations

impl NewTopic

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

Creates a topic using automatic replica assignment.

pub fn with_assignments( name: impl Into<String>, assignments: impl IntoIterator<Item = (i32, Vec<i32>)>, ) -> Self

Creates a topic using explicit partition-to-broker assignments.

Kafka requires partition count and replication factor to be -1 when manual assignments are supplied.

pub fn config(self, name: impl Into<String>, value: impl Into<String>) -> Self

Adds or replaces a topic configuration value.

pub fn nullable_config( self, name: impl Into<String>, value: Option<String>, ) -> Self

Adds or replaces a nullable topic configuration value.

pub fn name(&self) -> &str

Returns the topic name.

pub fn num_partitions(&self) -> i32

Returns the requested partition count, or -1 for manual assignment.

pub fn replication_factor(&self) -> i16

Returns the requested replication factor, or -1 for manual assignment.

pub fn assignments(&self) -> &BTreeMap<i32, Vec<i32>>

Returns explicit partition assignments in partition order.

pub fn configs(&self) -> &BTreeMap<String, Option<String>>

Returns topic configuration values in configuration-name order.

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.

impl Eq for NewTopic

impl PartialEq for NewTopic

fn eq(&self, other: &NewTopic) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for NewTopic