Function verify_kafka_topics_exhausted 

pub(crate) async fn verify_kafka_topics_exhausted(
    state: &State,
) -> Result<(), Error>