risingwave_simulation::kafka

Function create_topics

Source 
pub async fn create_topics(broker_addr: &str, topics: HashMap<String, i32>)
Expand description

Create a kafka topic