kafrust 0.2.28

A pure Rust Kafka client with no librdkafka or C client binding dependency.
Documentation 
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
27
28
29
30

mod common;

use kafrust::{AdminClient, ClientConfig, Error, ListTransactionsOptions};

#[tokio::main]
async fn main() -> kafrust::Result<()> {
    let config = common::apply_security(
        ClientConfig::new(common::bootstrap_servers_from_env())
            .client_id("kafrust-admin-list-transactions"),
    )?;
    let admin = AdminClient::new(config);
    let result = admin
        .list_transactions(ListTransactionsOptions::new())
        .await?;

    if !result.is_success() {
        return Err(Error::Broker {
            code: result.error_code(),
            context: "ListTransactions returned a top-level broker error".to_owned(),
        });
    }

    println!(
        "listed transactions={} unknown_states={} throttle={:?}",
        result.transactions().len(),
        result.unknown_state_filters().len(),
        result.throttle_time(),
    );
    Ok(())
}