rustainers 0.15.1

A simple, opinionated way to run containers for tests.
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

//! Example to show how we can use red panda

use std::time::Duration;

use rdkafka::producer::{FutureProducer, FutureRecord};
use rdkafka::ClientConfig;
use tracing::{info, Level};

use rustainers::compose::images::Redpanda;
use rustainers::runner::Runner;

mod common;
pub use self::common::*;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    init_tracing(Level::DEBUG);

    let runner = Runner::auto()?;
    let image = Redpanda::build_single().await?;

    let containers = runner.compose_start(image).await?;

    info!("Now I can use {containers}");
    do_something_with_kafka(&containers).await?;

    Ok(())
}

async fn do_something_with_kafka(image: &Redpanda) -> anyhow::Result<()> {
    let topic = "plop";
    let broker_address = image.broker_address().await?;
    info!("Using kafka broker: {broker_address}");

    let schema_registry_url = image.schema_registry_endpoint().await?;
    info!("Using schema registry: {schema_registry_url}");

    let mut config = ClientConfig::new();
    config.set("bootstrap.servers", broker_address);
    config.set("message.timeout.ms", "5000");
    info!("Config {config:#?}");

    let producer: &FutureProducer = &config.create()?;
    let record = FutureRecord::to(topic).payload("plop").key(&());
    let sent = producer
        .send(record, Duration::from_secs(0))
        .await
        .map_err(|(err, _)| err)?;
    info!("✉️ {sent:?}");

    Ok(())
}