Skip to main content

ensure_topic_with_replication_factor

Function ensure_topic_with_replication_factor 

Source
pub async fn ensure_topic_with_replication_factor(
    bootstrap: &str,
    topic: &str,
    partitions: i32,
    security: Option<ClientSecurity>,
    replication_factor: ReplicationFactor,
) -> Result<(), String>
Expand description

Ensure a topic with an explicit replication factor.

ยงErrors

Returns an error when the admin client cannot create or inspect the topic.