Crate tower_kafka

Source
Expand description

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

Modules§

  • connect
    Utilities for defining an underlying connection for the Kafka transport. Currently, we only expose a basic TCP connection, but in the future this can handle functionality like SASL, SSL, etc., without leaking these details into our main service.
  • error
    Errors produced by the service.
  • transport
    The lower level transport layer for communicating with Kafka, providing a multiplexed client over a given connection. Kafka uses a correlation identifier on each message provided by the client to track responses for a particular message. The Kafka protocol itself is length delimited.

Structs§

  • KafkaService
    A service for interacting with Apache Kafka.
  • MakeService
    Helper for constructing new service instances from a connection.

Type Aliases§