tower-kafka

用于与Apache Kafka交互的tower服务（工作进度）。

lib.rs:

tower-kafka

与Apache Kafka交互的服务层。

示例

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();