kafka_client 0.1.1

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

//! 批量消息测试
//!
//! 验证 100 条消息的批量生产和消费。
//!
//! 运行: KAFKA_RUNTIME=direct cargo test --test large_batch --features integration_tests -- --nocapture

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

mod common;

use common::KafkaInstance;

#[tokio::test]
async fn test_large_batch() {
    let server = KafkaInstance::start().await;
    let client = server.build_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()
    );
}