tower-kafka

A tower service for interacting with Apache Kafka (WIP).

lib.rs:

tower-kafka

A tower service for interacting with Apache Kafka.

Example

use tower_kafka::KafkaService;

    use tower_kafka::connect::TcpConnection;
    use tower_kafka::MakeService;
    let connection = TcpConnection::new("127.0.0.1:9093".parse().unwrap());
    let svc = MakeService::new(connection).into_service().await.unwrap();