Function mz_coord::sink_connector::register_kafka_topic
source · [−]async fn register_kafka_topic(
client: &AdminClient<MzClientContext>,
topic: &str,
partition_count: i32,
replication_factor: i32,
succeed_if_exists: bool,
retention: KafkaSinkConnectorRetention
) -> Result<(), CoordError>