initSidebarItems({"constant":[["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(..)`"]],"enum":[["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`."]],"mod":[["fetch","A representation of fetched messages from Kafka."],["metadata","Types related to topic metadata for introspection by clients. Example: `KafkaClient::topics()`."]],"struct":[["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."]]});