messaging_kafka_provider/
main.rs

1
2
3
4
5
6
7
8
9
10
11
12
//! Kafka implementation for wasmcloud:messaging.

use anyhow::Context as _;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    wasmcloud_provider_messaging_kafka::run()
        .await
        .context("failed to run provider")?;
    eprintln!("Kafka messaging provider exiting");
    Ok(())
}