Module tower_kafka::transport
source · Expand description
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
tokio-tower tag store for the Kafka protocol.A simple wrapper around
codec::LengthDelimitedCodec, which ensures
protocol frames are well formed.A service wrapper for transporting bytes to Kafka.
Helper for building new clients.
Enums
Errors that can be returned from the underlying transport layer.
Type Definitions
A multiplexed client that handles correlation ids.
A transport error occurred in the transport client.