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 Definitions

KafkaRequest
A Kafka request.
KafkaResponse
A Kafka response.