kafka_client 0.5.2

A pure Rust Kafka client library with SASL authentication support
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
31

#![cfg(feature = "integration_tests")]

mod common;

use common::build_test_client;
use common::compose;
use common::run_with_timeout;

async fn setup() {
    compose::ensure(&compose::clusters::THREE_BROKER).await;
}

#[tokio::test]
async fn test_large_batch() {
    run_with_timeout(async {
        setup().await;
        let client = build_test_client().await;

        common::create_topic(&client, "tc-large", 3).await;
        common::produce_messages(&client, "tc-large", 100).await;

        let records = common::consume_all(&client, "cg-large", "tc-large", 100).await;
        println!("  Consumed {} messages from 'tc-large'", records.len());
        assert!(
            records.len() >= 100,
            "Expected at least 100, got {}",
            records.len()
        );
    })
    .await;
}