Module kafka::client [−] [src]

Kafka Client - A mid-level abstraction for a kafka cluster allowing building higher level constructs.

The entry point into this module is KafkaClient obtained by a call to KafkaClient::new.

Modules

fetch	A representation of fetched messages from Kafka.
metadata	Types related to topic metadata for introspection by clients. Example: `KafkaClient::topics()`.

CommitOffset	Data point identifying a particular topic partition offset to be commited. See `KafkaClient::commit_offsets`.
FetchGroupOffset	Data point identifying a topic partition to fetch a group's offset for. See `KafkaClient::fetch_group_offsets`.
FetchPartition	Partition related request data for fetching messages. See `KafkaClient::fetch_messages`.
KafkaClient	Client struct keeping track of brokers and topic metadata.
PartitionOffset	A retrieved offset for a particular partition in the context of an already known topic.
ProduceMessage	Message data to be sent/produced to a particular topic partition. See `KafkaClient::produce_messages` and `Producer::send`.
TopicPartitionOffset	A retrieved offset of a particular topic partition.

Compression	Compression types supported by kafka. The numeral values of this enumeration correspond to the compression encoding in the attributes of a Message in the protocol.
FetchOffset	Possible values when querying a topic's offset. See `KafkaClient::fetch_offsets`.

DEFAULT_COMPRESSION	The default value for `KafkaClient::set_compression(..)`
DEFAULT_FETCH_MAX_BYTES_PER_PARTITION	The default value for `KafkaClient::set_fetch_max_bytes(..)`
DEFAULT_FETCH_MAX_WAIT_TIME	The default value for `KafkaClient::set_fetch_max_wait_time(..)`
DEFAULT_FETCH_MIN_BYTES	The default value for `KafkaClient::set_fetch_min_bytes(..)`