log_store::kafka

Module consumer

Source

Structs§

Consumer
The Consumer struct represents a Kafka consumer that fetches messages from a Kafka cluster. Yielding records respecting the RegionWalIndexIterator.
ConsumerBuilder
Builder for Consumer.
FetchResult 🔒
RecordsBuffer 🔒

Enums§

ConsumerBuilderError
Error type for ConsumerBuilder

Constants§

AVG_RECORD_SIZE 🔒
MAX_BATCH_SIZE 🔒

Traits§

FetchClient