Struct TopicConfig 

pub struct TopicConfig {
    pub name: String,
    pub partitions: u32,
    pub replication_factor: u16,
    pub retention_ms: u64,
    pub segment_bytes: u64,
    pub min_isr: u16,
    pub config: HashMap<String, String>,
}

Topic configuration

Fields

name: String

Topic name

partitions: u32

Number of partitions

replication_factor: u16

Replication factor

retention_ms: u64

Retention period in milliseconds

segment_bytes: u64

Segment size in bytes

min_isr: u16

Minimum ISR required for writes

config: HashMap<String, String>

Custom configuration

Implementations

impl TopicConfig

pub fn new( name: impl Into<String>, partitions: u32, replication_factor: u16, ) -> Self

pub fn with_retention_ms(self, ms: u64) -> Self

pub fn with_min_isr(self, min_isr: u16) -> Self

Trait Implementations

impl Clone for TopicConfig

fn clone(&self) -> TopicConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopicConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TopicConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for TopicConfig

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for TopicConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for TopicConfig

impl StructuralPartialEq for TopicConfig