rustfs-kafka-async

Async wrappers for rustfs-kafka, built on top of tokio.

This crate provides:

• AsyncKafkaClient
• AsyncProducer
• AsyncProducerBuilder
• AsyncConsumer
• AsyncConsumerBuilder

The current implementation uses background tasks/threads to bridge the sync core APIs.

Producer/consumer creation uses async builders and blocking-safe handoff so sync Kafka setup does not stall the tokio scheduler.

Installation

[dependencies]
rustfs-kafka-async = "1.1.0"

Quick Example

use rustfs_kafka::producer::Record;
use rustfs_kafka_async::AsyncProducer;

#[tokio::main]
async fn main() -> rustfs_kafka::Result<()> {
    let producer = AsyncProducer::builder(vec!["localhost:9092".to_owned()])
        .with_client_id("example-async-producer".to_owned())
        .build()
        .await?;
    producer.send(&Record::from_value("my-topic", b"hello async")).await?;
    producer.flush().await?;
    producer.close().await?;
    Ok(())
}

Notes

• This crate is intentionally lightweight and reuses the mature sync protocol/client logic from rustfs-kafka.
• Native async producer path now supports metadata-backed auto partition resolution.
• For full feature details, consult the root crate docs and docs/usage-guide.md in the repository.