messaging_kafka_provider/
main.rs

1//! Kafka implementation for wasmcloud:messaging.
2
3use anyhow::Context as _;
4
5#[tokio::main]
6async fn main() -> anyhow::Result<()> {
7    wasmcloud_provider_messaging_kafka::run()
8        .await
9        .context("failed to run provider")?;
10    eprintln!("Kafka messaging provider exiting");
11    Ok(())
12}