kafgrind/
lib.rs

1use std::collections::HashMap;
2
3
4
5pub mod args;
6pub mod kafka;
7pub mod producer;
8pub mod consumer;
9
10pub fn generate_payload(size_in_bytes: usize) -> String {
11    let mut payload = String::with_capacity(size_in_bytes);
12    let mut index = 0;
13    while index < payload.capacity() {
14        payload.push('a');
15        index = index + 1;
16    }
17    payload
18}