var searchIndex = {};
searchIndex["kafka"] = {"doc":"","items":[[0,"error","kafka","",null,null],[4,"Error","kafka::error","The error type for various operations.",null,null],[13,"Io","","",0,null],[13,"InvalidInputSnappy","","",0,null],[13,"UnexpectedEOF","","",0,null],[13,"CodecError","","",0,null],[13,"NoHostReachable","","",0,null],[13,"Unknown","","",0,null],[13,"OffsetOutOfRange","","",0,null],[13,"InvalidMessage","","",0,null],[13,"UnknownTopicOrPartition","","",0,null],[13,"InvalidMessageSize","","",0,null],[13,"LeaderNotAvailable","","",0,null],[13,"NotLeaderForPartition","","",0,null],[13,"RequestTimedOut","","",0,null],[13,"BrokerNotAvailable","","",0,null],[13,"ReplicaNotAvailable","","",0,null],[13,"MessageSizeTooLarge","","",0,null],[13,"StaleControllerEpochCode","","",0,null],[13,"OffsetMetadataTooLargeCode","","",0,null],[13,"OffsetsLoadInProgressCode","","",0,null],[13,"ConsumerCoordinatorNotAvailableCode","","",0,null],[13,"NotCoordinatorForConsumerCode","","",0,null],[6,"Result","","A type for results generated by this crate's functions where the `Err` type\nis hard-wired to `enums::Error`.",null,null],[11,"fmt","","",0,null],[11,"from_i16","","",0,{"inputs":[{"name":"i16"}],"output":{"name":"option"}}],[11,"from_i64","","",0,{"inputs":[{"name":"i64"}],"output":{"name":"option"}}],[11,"from_u64","","",0,{"inputs":[{"name":"u64"}],"output":{"name":"option"}}],[11,"from","","",0,{"inputs":[{"name":"error"}],"output":{"name":"error"}}],[11,"from","","",0,{"inputs":[{"name":"error"}],"output":{"name":"error"}}],[11,"description","","",0,null],[11,"cause","","",0,null],[11,"fmt","","",0,null],[0,"utils","kafka","",null,null],[3,"OffsetMessage","kafka::utils","",null,null],[12,"offset","","",1,null],[12,"message","","",1,null],[3,"TopicMessage","","",null,null],[12,"topic","","",2,null],[12,"partition","","",2,null],[12,"offset","","",2,null],[12,"error","","",2,null],[12,"message","","",2,null],[3,"ProduceMessage","","",null,null],[12,"topic","","",3,null],[12,"message","","",3,null],[3,"PartitionOffset","","",null,null],[12,"partition","","",4,null],[12,"offset","","",4,null],[3,"TopicPartitionOffset","","",null,null],[12,"topic","","",5,null],[12,"partition","","",5,null],[12,"offset","","",5,null],[3,"TopicPartitionOffsetError","","",null,null],[12,"topic","","",6,null],[12,"partition","","",6,null],[12,"offset","","",6,null],[12,"error","","",6,null],[3,"TopicPartitions","","",null,null],[12,"topic","","",7,null],[12,"partitions","","",7,null],[3,"TopicPartition","","",null,null],[12,"topic","","",8,null],[12,"partition","","",8,null],[11,"fmt","","",1,null],[11,"clone","","",1,null],[11,"fmt","","",2,null],[11,"fmt","","",3,null],[11,"clone","","",3,null],[11,"fmt","","",4,null],[11,"fmt","","",5,null],[11,"fmt","","",6,null],[11,"fmt","","",7,null],[11,"fmt","","",8,null],[0,"client","kafka","",null,null],[3,"KafkaClient","kafka::client","Client struct.",null,null],[12,"topic_partitions","","HashMap where `topic` is the key and list of `partitions` is the value",9,null],[11,"fmt","","",9,null],[11,"default","","",9,{"inputs":[],"output":{"name":"kafkaclient"}}],[11,"new","","Create a new instance of KafkaClient",9,{"inputs":[{"name":"vec"}],"output":{"name":"kafkaclient"}}],[11,"load_metadata_all","","Resets and loads metadata for all topics.",9,null],[11,"load_metadata","","Reloads metadata for a list of supplied topics",9,null],[11,"reset_metadata","","Clears metadata stored in the client. You must load metadata after this call if you want\nto use the client",9,null],[11,"fetch_offsets","","Fetch offsets for a list of topics.",9,null],[11,"fetch_topic_offset","","Fetch offset for a topic.",9,null],[11,"fetch_messages_multi","","Fetch messages from Kafka (Multiple topic, partition, offset)",9,null],[11,"fetch_messages","","Fetch messages from Kafka (Single topic, partition, offset)",9,null],[11,"send_messages","","Send a message to Kafka",9,null],[11,"send_message","","Send a message to Kafka",9,null],[11,"commit_offsets","","Commit offset to topic, partition of a consumer group",9,null],[11,"commit_offset","","Commit offset to topic, partition of a consumer group",9,null],[11,"fetch_group_topics_offset","","Fetch offset for vector of topic, partition of a consumer group",9,null],[11,"fetch_group_topic_offset","","Fetch offset for all partitions of a topic of a consumer group",9,null],[11,"fetch_group_offset","","Fetch offset for all partitions of all topics of a consumer group",9,null]],"paths":[[4,"Error"],[3,"OffsetMessage"],[3,"TopicMessage"],[3,"ProduceMessage"],[3,"PartitionOffset"],[3,"TopicPartitionOffset"],[3,"TopicPartitionOffsetError"],[3,"TopicPartitions"],[3,"TopicPartition"],[3,"KafkaClient"]]};
initSearch(searchIndex);