非官方 Rust Redpanda 测试容器

非官方 Redpanda 测试容器。Redpanda 是一个简单、强大且成本效益高的流式数据处理平台，兼容 Kafka API，但比 Kafka 更简单、更快、更便宜。

添加依赖项

testcontainers-redpanda-rs = { version = "0.7" }

创建并运行 Redpanda 容器

use testcontainers_redpanda_rs::*;

#[tokio::main]
async fn main() {
    let container = Redpanda::latest();

    let server_node = container.start().await.unwrap();
    let bootstrap_servers = format!("localhost:{}", server_node.get_host_port_ipv4(REDPANDA_PORT).await.unwrap());
    // if topic has only one partition this part is optional
    // it will be automatically created when client connects
    server_node.exec(Redpanda::cmd_create_topic("test_topic", 3)).await.unwrap();

    println!("Redpanda server: {}", bootstrap_servers);
}

关于版本兼容性的说明

• 0.7.x 支持 testcontainers 0.21
• 0.6.x 支持 testcontainers 0.20
• 0.5.x 支持 testcontainers 0.19
• 0.4.x 支持 testcontainers 0.18
• 0.3.x 支持 testcontainers 0.17
• 0.2.x 支持 testcontainers 0.16
• 0.1.x 支持 testcontainers 0.15