Struct KafkaTopicSpec 

pub struct KafkaTopicSpec {
    pub name: String,
    pub partitions: Option<i32>,
    pub replication: Option<i16>,
    pub mode: TopologyMode,
}

Topic configuration used when provisioning Kafka at startup.

Fields

name: String

partitions: Option<i32>

replication: Option<i16>

mode: TopologyMode

Implementations

impl KafkaTopicSpec

pub fn new(name: impl Into<String>) -> Self

pub fn partitions(self, partitions: i32) -> Self

pub fn replication(self, replication: i16) -> Self

pub fn mode(self, mode: TopologyMode) -> Self

Override the topology mode used when preparing this topic.

Trait Implementations

impl Clone for KafkaTopicSpec

fn clone(&self) -> KafkaTopicSpec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaTopicSpec

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

Formats the value using the given formatter.