Module kafka_rs::client

Kafka client implementation.

Structs

• 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.

Constants

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

Type Aliases

• MessageHeaders
  Headers of a message.
• Result
  Client results from interaction with a Kafka cluster.