fn verify_topic_exhausted( config: ClientConfig, topic: &str, timeout: Duration, ) -> Result<(), Error>