Struct ControllerClient 

pub struct ControllerClient { /* private fields */ }

Implementations

impl ControllerClient

pub async fn create_topic( &self, name: impl Into<String> + Send, num_partitions: i32, replication_factor: i16, timeout_ms: i32, ) -> Result<()>

Create a topic

pub async fn delete_topic( &self, name: impl Into<String> + Send, timeout_ms: i32, ) -> Result<()>

Delete a topic

Trait Implementations

impl Debug for ControllerClient

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

Formats the value using the given formatter.