skafka 0.1.0

A simple kafka wrapper for rdkafka
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

#[tokio::main]
async fn main() {
    let mut cfg = skafka::Config::new();
    cfg.set_brokers(&["192.168.102.8:9092"])
        .set_socket_timeout_ms(3000);

    let client = skafka::Client::build(cfg).unwrap();
    println!("{:?}", client.simple_create_topic("test_msg2", 1, 1).await);
    println!("{:?}", client.simple_create_partition("test_msg2", 1).await);
    println!("{:?}", client.simple_delete_record("test_msg2", 0, 1).await);
    println!("{:?}", client.simple_delete_group("test_msg_group").await);
    println!("{:?}", client.simple_delete_topic("test_msg2").await);
}