mz_testdrive/action/kafka/
delete_topic.rs1use crate::action::{ControlFlow, State};
11use crate::parser::BuiltinCommand;
12
13pub async fn run_delete_topic(
14 mut cmd: BuiltinCommand,
15 state: &mut State,
16) -> Result<ControlFlow, anyhow::Error> {
17 let topic_prefix = format!("testdrive-{}", cmd.args.string("topic")?);
18 cmd.args.done()?;
19
20 let topic_name = format!("{}-{}", topic_prefix, state.seed);
21
22 println!("Deleting Kafka topic {topic_name}");
23
24 mz_kafka_util::admin::delete_topic(&state.kafka_admin, &state.kafka_admin_opts, &topic_name)
25 .await?;
26 state.kafka_topics.remove(&topic_name);
27 Ok(ControlFlow::Continue)
28}