#![allow(dead_code)] // use std::collections::HashMap; // use std::env::{self, VarError}; // use std::sync::atomic::{AtomicUsize, Ordering}; // use std::sync::Arc; // use std::time::Duration; // use rand::Rng; // use regex::Regex; // pub fn rand_test_topic() -> String { // let id = rand::thread_rng() // .gen_ascii_chars() // .take(10) // .collect::(); // format!("__test_{}", id) // } // pub fn rand_test_group() -> String { // let id = rand::thread_rng() // .gen_ascii_chars() // .take(10) // .collect::(); // format!("__test_{}", id) // }