Module client

Source
Expand description

Kafka client implementation.

Structs§

Admin
Client
A Kafka client.
Message
A message to be encoded as a Kafka record within a record batch.
TopicProducer
A producer for a specific topic.

Enums§

Acks
Write acknowledgements required for a request.
ListOffsetsPosition
The position in a log to fetch an offset for.

Constants§

DEFAULT_TIMEOUT
The default timeout used for requests (10s).

Type Aliases§

MessageHeaders
Headers of a message.