kmailbox 0.1.6

A simple kafka mailbox
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

#[tokio::main]
async fn main() {
    let builder =  kmailbox::Builder::new(&["192.168.102.8:9092"]);
    let r = builder.all_metas().unwrap();
    for v in r {
        println!("meta:{:?}", v);
    }

    println!("==================================");

    let r = builder.metas(&["test-exclusive"]).unwrap();
    for (name, v) in r {
        println!("name:{name}, metas: {:?}", v);
    }
}