kafka-replicator 0.5.1

Application for replication data between kafka clusters.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

#![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::<String>();
//     format!("__test_{}", id)
// }

// pub fn rand_test_group() -> String {
//     let id = rand::thread_rng()
//         .gen_ascii_chars()
//         .take(10)
//         .collect::<String>();
//     format!("__test_{}", id)
// }