python-kafka-doc 0.9.5-2 / usr / share / doc / python-kafka-doc / html / searchindex.js

Search.setIndex({envversion:49,filenames:["apidoc/kafka","apidoc/kafka.consumer","apidoc/kafka.partitioner","apidoc/kafka.producer","apidoc/modules","index","install","tests","usage"],objects:{"":{kafka:[0,0,0,"-"]},"kafka.KafkaClient":{CLIENT_ID:[0,1,1,""],close:[0,3,1,""],copy:[0,3,1,""],ensure_topic_exists:[0,3,1,""],get_partition_ids_for_topic:[0,3,1,""],has_metadata_for_topic:[0,3,1,""],load_metadata_for_topics:[0,3,1,""],reinit:[0,3,1,""],reset_all_metadata:[0,3,1,""],reset_topic_metadata:[0,3,1,""],send_consumer_metadata_request:[0,3,1,""],send_fetch_request:[0,3,1,""],send_metadata_request:[0,3,1,""],send_offset_commit_request:[0,3,1,""],send_offset_fetch_request:[0,3,1,""],send_offset_fetch_request_kafka:[0,3,1,""],send_offset_request:[0,3,1,""],send_produce_request:[0,3,1,""],topics:[0,1,1,""]},"kafka.KafkaConnection":{close:[0,3,1,""],copy:[0,3,1,""],get_connected_socket:[0,3,1,""],recv:[0,3,1,""],reinit:[0,3,1,""],send:[0,3,1,""]},"kafka.KafkaConsumer":{DEFAULT_CONFIG:[0,1,1,""],close:[0,3,1,""],commit:[0,3,1,""],configure:[0,3,1,""],fetch_messages:[0,3,1,""],get_partition_offsets:[0,3,1,""],next:[0,3,1,""],offsets:[0,3,1,""],set_topic_partitions:[0,3,1,""],task_done:[0,3,1,""]},"kafka.KeyedProducer":{send:[0,3,1,""],send_messages:[0,3,1,""]},"kafka.MultiProcessConsumer":{get_messages:[0,3,1,""],stop:[0,3,1,""]},"kafka.RoundRobinPartitioner":{partition:[0,3,1,""]},"kafka.SimpleConsumer":{get_message:[0,3,1,""],get_messages:[0,3,1,""],reset_partition_offset:[0,3,1,""],seek:[0,3,1,""]},"kafka.SimpleProducer":{send_messages:[0,3,1,""]},"kafka.client":{KafkaClient:[0,2,1,""]},"kafka.client.KafkaClient":{CLIENT_ID:[0,1,1,""],close:[0,3,1,""],copy:[0,3,1,""],ensure_topic_exists:[0,3,1,""],get_partition_ids_for_topic:[0,3,1,""],has_metadata_for_topic:[0,3,1,""],load_metadata_for_topics:[0,3,1,""],reinit:[0,3,1,""],reset_all_metadata:[0,3,1,""],reset_topic_metadata:[0,3,1,""],send_consumer_metadata_request:[0,3,1,""],send_fetch_request:[0,3,1,""],send_metadata_request:[0,3,1,""],send_offset_commit_request:[0,3,1,""],send_offset_fetch_request:[0,3,1,""],send_offset_fetch_request_kafka:[0,3,1,""],send_offset_request:[0,3,1,""],send_produce_request:[0,3,1,""],topics:[0,1,1,""]},"kafka.codec":{gzip_decode:[0,4,1,""],gzip_encode:[0,4,1,""],has_gzip:[0,4,1,""],has_snappy:[0,4,1,""],snappy_decode:[0,4,1,""],snappy_encode:[0,4,1,""]},"kafka.common":{AsyncProducerQueueFull:[0,5,1,""],BrokerMetadata:[0,2,1,""],BrokerNotAvailableError:[0,5,1,""],BrokerResponseError:[0,5,1,""],BufferUnderflowError:[0,5,1,""],ChecksumError:[0,5,1,""],ConnectionError:[0,5,1,""],ConsumerCoordinatorNotAvailableCode:[0,5,1,""],ConsumerFetchSizeTooSmall:[0,5,1,""],ConsumerMetadataRequest:[0,2,1,""],ConsumerMetadataResponse:[0,2,1,""],ConsumerNoMoreData:[0,5,1,""],ConsumerTimeout:[0,5,1,""],FailedPayloadsError:[0,5,1,""],FetchRequest:[0,2,1,""],FetchResponse:[0,2,1,""],InvalidFetchRequestError:[0,5,1,""],InvalidMessageError:[0,5,1,""],KafkaConfigurationError:[0,5,1,""],KafkaError:[0,5,1,""],KafkaMessage:[0,2,1,""],KafkaTimeoutError:[0,5,1,""],KafkaUnavailableError:[0,5,1,""],LeaderNotAvailableError:[0,5,1,""],Message:[0,2,1,""],MessageSizeTooLargeError:[0,5,1,""],MetadataRequest:[0,2,1,""],MetadataResponse:[0,2,1,""],NotCoordinatorForConsumerCode:[0,5,1,""],NotLeaderForPartitionError:[0,5,1,""],OffsetAndMessage:[0,2,1,""],OffsetCommitRequest:[0,2,1,""],OffsetCommitResponse:[0,2,1,""],OffsetFetchRequest:[0,2,1,""],OffsetFetchResponse:[0,2,1,""],OffsetMetadataTooLargeError:[0,5,1,""],OffsetOutOfRangeError:[0,5,1,""],OffsetRequest:[0,2,1,""],OffsetResponse:[0,2,1,""],OffsetsLoadInProgressCode:[0,5,1,""],PartitionMetadata:[0,2,1,""],ProduceRequest:[0,2,1,""],ProduceResponse:[0,2,1,""],ProtocolError:[0,5,1,""],ReplicaNotAvailableError:[0,5,1,""],RequestTimedOutError:[0,5,1,""],RetryOptions:[0,2,1,""],StaleControllerEpochError:[0,5,1,""],StaleLeaderEpochCodeError:[0,5,1,""],TopicAndPartition:[0,2,1,""],TopicMetadata:[0,2,1,""],UnknownError:[0,5,1,""],UnknownTopicOrPartitionError:[0,5,1,""],UnsupportedCodecError:[0,5,1,""],check_error:[0,4,1,""],x:[0,1,1,""]},"kafka.common.BrokerMetadata":{host:[0,1,1,""],nodeId:[0,1,1,""],port:[0,1,1,""]},"kafka.common.BrokerNotAvailableError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.ConsumerCoordinatorNotAvailableCode":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.ConsumerMetadataRequest":{groups:[0,1,1,""]},"kafka.common.ConsumerMetadataResponse":{error:[0,1,1,""],host:[0,1,1,""],nodeId:[0,1,1,""],port:[0,1,1,""]},"kafka.common.FetchRequest":{max_bytes:[0,1,1,""],offset:[0,1,1,""],partition:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.FetchResponse":{error:[0,1,1,""],highwaterMark:[0,1,1,""],messages:[0,1,1,""],partition:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.InvalidFetchRequestError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.InvalidMessageError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.KafkaMessage":{key:[0,1,1,""],offset:[0,1,1,""],partition:[0,1,1,""],topic:[0,1,1,""],value:[0,1,1,""]},"kafka.common.LeaderNotAvailableError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.Message":{attributes:[0,1,1,""],key:[0,1,1,""],magic:[0,1,1,""],value:[0,1,1,""]},"kafka.common.MessageSizeTooLargeError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.MetadataRequest":{topics:[0,1,1,""]},"kafka.common.MetadataResponse":{brokers:[0,1,1,""],topics:[0,1,1,""]},"kafka.common.NotCoordinatorForConsumerCode":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.NotLeaderForPartitionError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.OffsetAndMessage":{message:[0,1,1,""],offset:[0,1,1,""]},"kafka.common.OffsetCommitRequest":{metadata:[0,1,1,""],offset:[0,1,1,""],partition:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.OffsetCommitResponse":{error:[0,1,1,""],partition:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.OffsetFetchRequest":{partition:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.OffsetFetchResponse":{error:[0,1,1,""],metadata:[0,1,1,""],offset:[0,1,1,""],partition:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.OffsetMetadataTooLargeError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.OffsetOutOfRangeError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.OffsetRequest":{max_offsets:[0,1,1,""],partition:[0,1,1,""],time:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.OffsetResponse":{error:[0,1,1,""],offsets:[0,1,1,""],partition:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.OffsetsLoadInProgressCode":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.PartitionMetadata":{error:[0,1,1,""],isr:[0,1,1,""],leader:[0,1,1,""],partition:[0,1,1,""],replicas:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.ProduceRequest":{messages:[0,1,1,""],partition:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.ProduceResponse":{error:[0,1,1,""],offset:[0,1,1,""],partition:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.ReplicaNotAvailableError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.RequestTimedOutError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.RetryOptions":{backoff_ms:[0,1,1,""],limit:[0,1,1,""],retry_on_timeouts:[0,1,1,""]},"kafka.common.StaleControllerEpochError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.StaleLeaderEpochCodeError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.TopicAndPartition":{partition:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.TopicMetadata":{error:[0,1,1,""],partitions:[0,1,1,""],topic:[0,1,1,""]},"kafka.common.UnknownError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.common.UnknownTopicOrPartitionError":{errno:[0,1,1,""],message:[0,1,1,""]},"kafka.conn":{KafkaConnection:[0,2,1,""],collect_hosts:[0,4,1,""]},"kafka.conn.KafkaConnection":{close:[0,3,1,""],copy:[0,3,1,""],get_connected_socket:[0,3,1,""],recv:[0,3,1,""],reinit:[0,3,1,""],send:[0,3,1,""]},"kafka.consumer":{KafkaConsumer:[1,2,1,""],MultiProcessConsumer:[1,2,1,""],SimpleConsumer:[1,2,1,""],base:[1,0,0,"-"],kafka:[1,0,0,"-"],multiprocess:[1,0,0,"-"],simple:[1,0,0,"-"]},"kafka.consumer.KafkaConsumer":{DEFAULT_CONFIG:[1,1,1,""],close:[1,3,1,""],commit:[1,3,1,""],configure:[1,3,1,""],fetch_messages:[1,3,1,""],get_partition_offsets:[1,3,1,""],next:[1,3,1,""],offsets:[1,3,1,""],set_topic_partitions:[1,3,1,""],task_done:[1,3,1,""]},"kafka.consumer.MultiProcessConsumer":{get_messages:[1,3,1,""],stop:[1,3,1,""]},"kafka.consumer.SimpleConsumer":{get_message:[1,3,1,""],get_messages:[1,3,1,""],reset_partition_offset:[1,3,1,""],seek:[1,3,1,""]},"kafka.consumer.base":{Consumer:[1,2,1,""]},"kafka.consumer.base.Consumer":{commit:[1,3,1,""],fetch_last_known_offsets:[1,3,1,""],pending:[1,3,1,""],provide_partition_info:[1,3,1,""],stop:[1,3,1,""]},"kafka.consumer.kafka":{KafkaConsumer:[1,2,1,""],OffsetsStruct:[1,2,1,""]},"kafka.consumer.kafka.KafkaConsumer":{DEFAULT_CONFIG:[1,1,1,""],close:[1,3,1,""],commit:[1,3,1,""],configure:[1,3,1,""],fetch_messages:[1,3,1,""],get_partition_offsets:[1,3,1,""],next:[1,3,1,""],offsets:[1,3,1,""],set_topic_partitions:[1,3,1,""],task_done:[1,3,1,""]},"kafka.consumer.kafka.OffsetsStruct":{commit:[1,1,1,""],fetch:[1,1,1,""],highwater:[1,1,1,""],task_done:[1,1,1,""]},"kafka.consumer.multiprocess":{Events:[1,2,1,""],MultiProcessConsumer:[1,2,1,""]},"kafka.consumer.multiprocess.Events":{exit:[1,1,1,""],pause:[1,1,1,""],start:[1,1,1,""]},"kafka.consumer.multiprocess.MultiProcessConsumer":{get_messages:[1,3,1,""],stop:[1,3,1,""]},"kafka.consumer.simple":{FetchContext:[1,2,1,""],SimpleConsumer:[1,2,1,""]},"kafka.consumer.simple.SimpleConsumer":{get_message:[1,3,1,""],get_messages:[1,3,1,""],reset_partition_offset:[1,3,1,""],seek:[1,3,1,""]},"kafka.context":{OffsetCommitContext:[0,2,1,""]},"kafka.context.OffsetCommitContext":{commit:[0,3,1,""],commit_partition_offsets:[0,3,1,""],handle_out_of_range:[0,3,1,""],mark:[0,3,1,""],rollback:[0,3,1,""],update_consumer_offsets:[0,3,1,""]},"kafka.partitioner":{HashedPartitioner:[2,1,1,""],LegacyPartitioner:[2,2,1,""],Murmur2Partitioner:[2,2,1,""],RoundRobinPartitioner:[2,2,1,""],base:[2,0,0,"-"],hashed:[2,0,0,"-"],roundrobin:[2,0,0,"-"]},"kafka.partitioner.LegacyPartitioner":{partition:[2,3,1,""]},"kafka.partitioner.Murmur2Partitioner":{partition:[2,3,1,""]},"kafka.partitioner.RoundRobinPartitioner":{partition:[2,3,1,""]},"kafka.partitioner.base":{Partitioner:[2,2,1,""]},"kafka.partitioner.base.Partitioner":{partition:[2,3,1,""]},"kafka.partitioner.hashed":{HashedPartitioner:[2,1,1,""],LegacyPartitioner:[2,2,1,""],Murmur2Partitioner:[2,2,1,""],murmur2:[2,4,1,""]},"kafka.partitioner.hashed.LegacyPartitioner":{partition:[2,3,1,""]},"kafka.partitioner.hashed.Murmur2Partitioner":{partition:[2,3,1,""]},"kafka.partitioner.roundrobin":{RoundRobinPartitioner:[2,2,1,""]},"kafka.partitioner.roundrobin.RoundRobinPartitioner":{partition:[2,3,1,""]},"kafka.producer":{KeyedProducer:[3,2,1,""],SimpleProducer:[3,2,1,""],base:[3,0,0,"-"],keyed:[3,0,0,"-"],simple:[3,0,0,"-"]},"kafka.producer.KeyedProducer":{send:[3,3,1,""],send_messages:[3,3,1,""]},"kafka.producer.SimpleProducer":{send_messages:[3,3,1,""]},"kafka.producer.base":{Producer:[3,2,1,""]},"kafka.producer.base.Producer":{ACK_AFTER_CLUSTER_COMMIT:[3,1,1,""],ACK_AFTER_LOCAL_WRITE:[3,1,1,""],ACK_NOT_REQUIRED:[3,1,1,""],DEFAULT_ACK_TIMEOUT:[3,1,1,""],send_messages:[3,3,1,""],stop:[3,3,1,""]},"kafka.producer.keyed":{KeyedProducer:[3,2,1,""]},"kafka.producer.keyed.KeyedProducer":{send:[3,3,1,""],send_messages:[3,3,1,""]},"kafka.producer.simple":{SimpleProducer:[3,2,1,""]},"kafka.producer.simple.SimpleProducer":{send_messages:[3,3,1,""]},"kafka.protocol":{KafkaProtocol:[0,2,1,""],create_gzip_message:[0,4,1,""],create_message:[0,4,1,""],create_message_set:[0,4,1,""],create_snappy_message:[0,4,1,""]},"kafka.protocol.KafkaProtocol":{CONSUMER_METADATA_KEY:[0,1,1,""],FETCH_KEY:[0,1,1,""],METADATA_KEY:[0,1,1,""],OFFSET_COMMIT_KEY:[0,1,1,""],OFFSET_FETCH_KEY:[0,1,1,""],OFFSET_KEY:[0,1,1,""],PRODUCE_KEY:[0,1,1,""],decode_consumer_metadata_response:[0,6,1,""],decode_fetch_response:[0,6,1,""],decode_metadata_response:[0,6,1,""],decode_offset_commit_response:[0,6,1,""],decode_offset_fetch_response:[0,6,1,""],decode_offset_response:[0,6,1,""],decode_produce_response:[0,6,1,""],encode_consumer_metadata_request:[0,6,1,""],encode_fetch_request:[0,6,1,""],encode_metadata_request:[0,6,1,""],encode_offset_commit_request:[0,6,1,""],encode_offset_fetch_request:[0,6,1,""],encode_offset_request:[0,6,1,""],encode_produce_request:[0,6,1,""]},"kafka.util":{ReentrantTimer:[0,2,1,""],crc32:[0,4,1,""],group_by_topic_and_partition:[0,4,1,""],kafka_bytestring:[0,4,1,""],read_int_string:[0,4,1,""],read_short_string:[0,4,1,""],relative_unpack:[0,4,1,""],write_int_string:[0,4,1,""],write_short_string:[0,4,1,""]},"kafka.util.ReentrantTimer":{start:[0,3,1,""],stop:[0,3,1,""]},kafka:{HashedPartitioner:[0,1,1,""],KafkaClient:[0,2,1,""],KafkaConnection:[0,2,1,""],KafkaConsumer:[0,2,1,""],KeyedProducer:[0,2,1,""],MultiProcessConsumer:[0,2,1,""],RoundRobinPartitioner:[0,2,1,""],SimpleConsumer:[0,2,1,""],SimpleProducer:[0,2,1,""],client:[0,0,0,"-"],codec:[0,0,0,"-"],common:[0,0,0,"-"],conn:[0,0,0,"-"],consumer:[1,0,0,"-"],context:[0,0,0,"-"],create_gzip_message:[0,4,1,""],create_message:[0,4,1,""],create_snappy_message:[0,4,1,""],partitioner:[2,0,0,"-"],producer:[3,0,0,"-"],protocol:[0,0,0,"-"],util:[0,0,0,"-"]}},objnames:{"0":["py","module","Python module"],"1":["py","attribute","Python attribute"],"2":["py","class","Python class"],"3":["py","method","Python method"],"4":["py","function","Python function"],"5":["py","exception","Python exception"],"6":["py","classmethod","Python class method"]},objtypes:{"0":"py:module","1":"py:attribute","2":"py:class","3":"py:method","4":"py:function","5":"py:exception","6":"py:classmethod"},terms:{"16k":[0,1],"32k":0,"\u4f60\u600e\u4e48\u6837":8,"_local":0,"_not_":0,"break":0,"byte":[0,1,2,3,8],"case":0,"class":[0,1,2,3,5],"default":[0,1,2,3,7,8],"float":3,"function":[0,1,2],"import":[0,8],"int":[0,1,3,8],"long":0,"new":0,"null":3,"return":[0,1,2,3],"throw":[0,1],"true":[0,1,3,8],"while":[0,8],about:5,absolut:[0,1],accept:[0,1],accumul:[0,1],ack:[0,3],ack_after_cluster_commit:[3,8],ack_after_local_write:[3,8],ack_not_required:3,ack_timeout:[3,8],acki:0,acknowledg:[0,3,8],actual:7,addition:[0,3],address:0,advanc:8,after:[0,1,3,8],against:7,aguidetothekafkaprotocol:[0,1],alia:[0,1,2],all:[0,1,3,7,8],all_codecs:3,alloc:[0,1],allow:[0,3],also:[0,1,5,6],alter:[0,1],although:0,alwai:[0,1,3],among:[0,1,8],amount:[0,1],ani:[0,1,8],anoth:[0,1,8],any:[0,1],apach:[0,1,2,5,8],api:[0,1,5],appli:[2,3],applic:8,apt:6,arg:[0,2,3],argument:[0,1,2,3],around:0,arthur:5,ask:[0,1],associ:0,assum:0,async:[3,8],async_log_messages_on_error:3,async_queue_maxs:3,async_queue_put_timeout:3,async_retry_backoff_m:3,async_retry_limit:3,async_retry_on_timeout:3,async_stop_timeout:3,asynchron:5,asyncproducerqueueful:0,atom:0,attempt:[2,3,8],attribut:[0,8],authors:5,auto:[0,1,8],auto_commit:[0,1],auto_commit_en:[0,1,8],auto_commit_every_n:[0,1],auto_commit_every_t:[0,1],auto_commit_interval_m:[0,1,8],auto_commit_interval_messag:[0,1],auto_offset_reset:[0,1,8],automat:[0,1],avail:[0,1,8],await:0,awar:5,back:[0,1],background:[0,3],backoff:[0,1,3],backoff_m:0,base:0,batch:[0,3,5,8],batch_send:3,batch_send_every_n:[3,8],batch_send_every_t:[3,8],becaus:[0,1],been:[0,1],befor:[0,1,3,8],begin:0,between:[0,1],binari:7,bleed:5,block1:0,block:[0,1,3,8],blocklen:0,blockn:0,blocksiz:0,bool:[0,1,3],bootstrap:[0,1],bootstrap_serv:[0,1,8],both:[0,1],brew:6,broker:[0,1,3,5,7],broker_not_available:0,brokermetadata:0,brokernotavailableerror:0,brokerresponseerror:0,buffer_s:[0,1],bufferunderflowerror:0,build:[6,7],build_integr:7,bytearrai:2,call:[0,1,3,8],callabl:[0,1],callback:0,can:[0,1,8],can_process:0,caus:[0,1],certain:[0,1],check:1,check_error:0,checksumerror:0,classmethod:0,cleanup:8,client_id:[0,1,8],clock:0,clone:6,close:[0,1,8],cluster:[0,1],code:[0,6],codec_compresslevel:3,codec_none:0,collect:[0,7,8],collect_host:0,com:[5,6],come:[0,1],comma:0,commit:[0,1,8],commit_partition_offset:0,commun:3,compar:0,compat:[0,5],complet:[0,1,3],compress:[0,3,5],compresslevel:0,condit:0,config:[0,1],configur:[0,1,3,6,8],confluenc:[0,1],connect:[0,1],connectionerror:0,construct:0,constructor:[0,1,8],consum:0,consumer_coordinator_not_available_code:0,consumer_group:[0,1],consumer_metadata_key:0,consumer_timeout_m:[0,1,8],consumercoordinatornotavailablecod:0,consumerfetchsizetoosmal:0,consumermetadatarequest:0,consumermetadatarespons:0,consumernomoredata:0,consumertimeout:[0,1],consumpt:[0,1],contact:[0,1],contain:0,continu:3,contributor:5,control:0,coordin:5,copi:[0,1,3],copyright:5,correct:0,correl:0,correlation_id:0,count:[0,1,8],crc32:0,creat:0,create_gzip_messag:0,create_messag:[0,8],create_message_set:0,create_snappy_messag:0,cur:0,current:[0,1,5,8],cwiki:[0,1],cycl:[0,3],dana:5,data:[0,1,2,8],david:5,debug:0,decod:[0,8],decode_consumer_metadata_respons:0,decode_fetch_respons:0,decode_metadata_respons:0,decode_offset_commit_respons:0,decode_offset_fetch_respons:0,decode_offset_respons:0,decode_produce_respons:0,default_ack_timeout:3,default_config:[0,1],default_fetcher_backoff_m:[0,1],defer:0,delai:0,deprec:3,deprecated:2,deriv:[0,3],descend:[0,1],describ:[0,1,8],deseri:[0,1],deserializer_class:[0,1,8],design:5,detail:[0,1,8],dev:6,develop:5,dict:[0,1],directli:[0,1,6],disabl:[0,1],discuss:5,disk:0,displai:[0,1],distribut:[0,3,7],divid:[0,1],do_some_work:8,document:[0,1,8],doe:[0,1],doesn:0,don:0,dont:[0,1],doubl:[0,1],download:[6,7],dpkp:6,duplic:0,dure:[0,1],each:[0,1,3,8],earliest:[0,1],easy_instal:6,edge:5,either:[0,1],element:[0,1],els:0,enabl:[0,1],encapsul:0,encod:[0,2,3,8],encode:0,encode_consumer_metadata_request:0,encode_fetch_request:0,encode_metadata_request:0,encode_offset_commit_request:0,encode_offset_fetch_request:0,encode_offset_request:0,encode_produce_request:0,end:0,ensur:0,ensure_topic_exist:0,env:7,errno:0,error:[0,1,3,8],even:3,event:1,eventual:0,everi:8,exampl:[0,1,3],except:[0,1,3],exception:0,exist:0,exit:[0,1],expect:[0,3],explicit:[0,1],extern:0,facilit:0,fail:3,fail_on_error:[0,8],failed_msg:0,failedpayloadserror:0,failur:[0,1,3],fals:[0,1,3,8],far:0,fashion:[0,2],favorit:6,fetch:[0,1],fetch_key:0,fetch_last_known_offset:[0,1],fetch_max_wait_m:[0,1],fetch_messag:[0,1,8],fetch_message_max_byt:[0,1,8],fetch_min_byt:[0,1,8],fetch_size_byt:[0,1],fetch_wait_max_m:[0,1,8],fetchapi:[0,1],fetchcontext:1,fetchrequest:[0,1],fetchrespons:0,fewer:3,field:[0,1],file:6,first:[0,3,7,8],fmt:0,follow:[0,8],forev:[0,1],format:0,forum:5,found:[0,1],freenod:5,frequent:0,fresh:0,from:[0,1,3,6,7,8],from_kafka:0,fseek:[0,1],full:[0,1,3],fulli:8,gener:[0,1,5],get:[0,1,3,6,7],get_connected_socket:0,get_messag:[0,1,8],get_partition_ids_for_top:0,get_partition_info:[0,1],get_partition_offset:[0,1],git:6,github:[0,1,6],given:0,googl:[5,6],googlecod:6,group:[0,1,5,8],group_by_topic_and_partit:0,group_id:[0,1,8],guid:[0,1],gzip:[0,5],gzip_decod:0,gzip_encod:0,handl:[0,8],handle_out_of_rang:0,happen:[0,1],has_gzip:0,has_metadata_for_top:0,has_snappi:0,hash:0,hashedpartition:[0,2,3,8],have:[0,1],head:[0,1],header:0,help:0,helper:3,here:0,high:[0,5],highlevelconsumerapi:[0,1,8],highwat:[0,1],highwatermark:0,hopefulli:8,host:0,how:[0,1],html:[0,1,8],http:[0,1,5,6,8],identifi:3,immedi:[0,3],implement:[0,1,2,5],inact:0,includ:[0,1,8],indefinit:[0,1],index:5,indic:[0,3],indicat:[0,1],infinit:8,info:[0,1,8],inform:5,initi:[0,1,3],initial:[0,1],input:0,instal:5,install:5,instanc:[0,1,3,7],instead:0,int32:0,integ:[0,1],integr:5,interfac:8,intern:[0,1,3],interv:0,invalid_fetch_size:0,invalid_message:0,invalidfetchrequesterror:0,invalidmessageerror:0,invok:0,irc:5,isr:0,issu:[0,1],issue:[2,5],iter:[0,1,8],iter_timeout:[0,1],java:[2,8],jitter:[0,1],join:[0,1],just:[0,1,3,8],kafka_bytestr:0,kafka_version:7,kafkacli:[0,1,3,8],kafkaconfigurationerror:0,kafkaconnect:0,kafkaconsum:[0,1,5],kafkaerror:0,kafkamessag:[0,1],kafkaprotocol:[0,8],kafkatimeouterror:0,kafkaunavailableerror:0,kei:[0,1,2],key1:8,key2:8,keyedproduc:[0,3,8],keyword:[0,1],know:0,known:[0,1],kwarg:[0,3],lambda:[0,1,8],largest:[0,1,8],last:0,latest:[0,1,5],leader:0,leader_not_available:0,leadernotavailableerror:0,least:[0,1],legacypartition:[0,2],len:0,length:0,less:0,level:[0,5],librari:0,libsnappi:6,license:5,like:[0,3,7],limit:[0,1,3],list:[0,1,2,6,7],listen:0,load_metadata_for_top:0,local:[0,3,7,8],localhost:8,log:[0,3,8],logic:1,loss:8,low:5,magic:0,mainlin:2,make:6,manag:[0,1,6,8],mani:[0,1],manual:[0,1],map:0,mark:[0,1,8],match:3,max:[0,1,8],max_buffer_s:[0,1],max_byt:0,max_num_offset:[0,1],max_offset:0,max_wait_tim:0,maximum:[0,1],mean:[0,1],messag:[0,1,2,3,5,7],message_size_too_large:0,messagesizetoolargeerror:0,metadata:[0,1],metadata_key:0,metadatarequest:0,metadatarespons:0,method:[0,1,3,8],millisecond:[0,1,3],min_byt:0,minimum:[0,1],mirror:8,mode:[3,5],modifi:[0,1],more:[0,1,3,8],most:[0,1],move:[0,1],msg:[0,1,3,8],much:[0,1],multipl:[0,1,8],multiplex:0,multiprocess:0,multiprocessconsum:[0,1,8],murmur2:2,murmur2partition:[2,8],murmurhash2:2,must:[0,1,3],my_consumer_group:8,my_group:8,name:[0,1,3,8],namedtupl:8,necessari:[0,8],need:[0,1],never:0,next:[0,1,8],node:[0,1],nodeid:0,none:[0,1,2,3,8],normal:[0,1],not_coordinator_for_consumer_code:0,not_leader_for_partition:0,notcoordinatorforconsumercod:0,note:[0,1,3,8],notleaderforpartitionerror:0,num_consumer_fetch:[0,1],num_partit:2,num_proc:[0,1,8],number:[0,1,3,7,8],object:[0,1,2,3],occur:0,offset:[0,1,8],offset_commit_key:0,offset_fetch_key:0,offset_key:0,offset_metadata_too_large:0,offset_out_of_range:0,offsetandmessag:0,offsetapi:[0,1],offsetcommit:[0,1],offsetcommitcontext:0,offsetcommitrequest:[0,1],offsetcommitrespons:0,offsetfetchrequest:0,offsetfetchrespons:0,offsetmetadatatoolargeerror:0,offsetoutofrang:[0,1],offsetoutofrangeerror:[0,1],offsetrequest:0,offsetrespons:[0,1],offsets_load_in_progress_code:0,offsetsloadinprogresscod:0,offsetsstruct:1,ofther:[0,1],oldest:[0,1],onli:[0,3,7],open:0,oper:[0,1],option:[0,1,2,3,7],optional:[0,1,5],order:[0,1],org:[0,1,2,5,8],organ:0,osx:6,other:1,otherwis:[0,1,3,8],out:0,output:[0,8],overrid:[0,1],own:0,packet:0,page:5,pair:0,parallel:[0,1],param:3,paramet:[0,1,8],parit:0,partit:[0,1,2,3,8],partition0:[0,1],partition2:[0,1],partition:0,partition_offset:0,partitionmetadata:0,partitions_per_proc:[0,1,8],pass:[0,1,3,8],past:0,paus:1,payload:[0,3,8],pend:1,per:[0,1],period:[0,1,8],pick:7,pip:6,pipelin:0,polici:[0,1],port:0,posit:[0,1],power:5,present:0,print:8,prior:[0,1],process:[0,1,8],process_messag:8,produc:0,produce_key:0,producerequest:[0,8],producerespons:0,protocolerror:0,provid:[0,1,5],provide_partition_info:[0,1],publish:[0,3],pull:[0,1],pure:[0,2],put:3,py27:7,pypi:[5,7],python:[0,2],queu:3,queue:3,queued_max_message_chunk:[0,1],rais:[0,1,3],random:[0,1,3],random_start:[0,3],rang:0,raw:[0,1,8],read_int_str:0,read_short_str:0,real:7,rebalance_backoff_m:[0,1],rebalance_max_retri:[0,1],receipt:0,receiv:[0,1,3],recent:[0,1],recommend:7,record:0,recv:0,reentranttim:0,refer:5,refresh:[0,1],refresh_leader_backoff_m:[0,1,8],reinit:0,rel:[0,1],relative_unpack:0,releas:5,rememb:8,repeat:0,replica:[0,8],replica_not_available:0,replicanotavailableerror:0,req:8,req_ack:[3,8],request:[0,1,3,5,8],request_id:0,request_time_m:[0,1],request_timed_out:0,requesttimedouterror:0,requesttimeouterror:3,requir:[0,1],reset:[0,1],reset_all_metadata:0,reset_partition_offset:[0,1],reset_topic_metadata:0,resolv:0,resp:8,respect:0,respond:[0,1,3],respons:[0,8],responserequest:3,restart:0,result:0,retri:[0,3],retry_on_timeout:0,retryopt:0,robin:[0,2,3,8],rollback:0,round:[0,2,3,8],roundrobin:0,roundrobinpartition:[0,2,8],rout:[0,5],run:5,runtimeerror:0,safe:[0,3],same:[0,2],scala_version:7,script:7,search:5,second:[0,1,3,8],see:[0,1,2,3,5],seek:[0,1],select:2,semant:0,send:[0,1,2,3,7,8],send_consumer_metadata_request:0,send_fetch_request:0,send_messag:[0,3,8],send_metadata_request:0,send_offset_commit_request:0,send_offset_fetch_request:0,send_offset_fetch_request_kafka:0,send_offset_request:0,send_produce_request:[0,8],sent:[0,3,8],separ:0,server:[0,1,3,7,8],set:[0,1,3,5,7,8],set_topic_partit:[0,1],setup:6,setuptool:6,should:[0,1,3],shutdown:0,similar:[0,1],simpl:0,simple_consumer_opt:[0,1],simpleconsum:[0,1],simpleproduc:[0,3,5],simpler:[0,1],simpli:[0,1,7],sinc:0,singl:[0,1],size:[0,3],sleep:0,smallest:[0,1,8],snappi:[0,5],snappy_decod:0,snappy_encod:0,socket:[0,1],socket_receive_buffer_byt:[0,1],socket_timeout_m:[0,1,8],some:[0,8],some_condit:0,someth:[0,3],sourc:[0,1,2,3,6,7],spawn:8,special:[0,1],specif:[0,3,5],specifi:[0,1],split:8,stabl:5,stale_controller_epoch:0,stale_leader_epoch_code:0,stalecontrollerepocherror:0,staleleaderepochcodeerror:0,start:[0,1,7],state:[0,1],stop:[0,1,3,8],storag:[0,1],store:[0,1],str:[0,1,3,8],stream:0,string:[0,2,8],struct:[0,1],subject:[0,1],submit:[0,1],subset:5,success:[0,1],sudo:6,suitabl:0,suppli:0,support:[0,1,5,7],sync:[0,3,8],sync_fail_on_error:[3,8],synchron:8,tail:[0,1],take:[0,1,2],tar:6,target:2,task_don:[0,1,8],tcp:[0,1],tell:[0,1],test:5,test_protocol:7,than:[0,3],thei:[0,1],them:[1,8],thi:[0,1,3,5,8],thread:[0,3],through:[0,3],till:[0,1,8],time:[0,1],timeout:[0,1,3,8],timer:0,topic1:[0,1,8],topic2:[0,1,8],topic3:[0,1],topic:[0,1,3,8],topicandpartit:0,topicmetadata:0,tox:7,trigger:[0,1],trunk:7,tupl:[0,1],two:[0,1,8],type:[0,1,2,3,8],ubuntu:6,uncompress:0,under:5,underli:[0,1],unicod:[3,8],unicode_messag:3,uniqu:[0,1],unit:5,unknown:0,unknown_topic_or_partiton:0,unknownerror:0,unknowntopicorpartitionerror:0,unless:[0,1],unlik:0,unlimit:3,unsuccess:0,unsuccessfulli:0,unsupportedcodecerror:0,until:[0,1,3,8],updat:[0,1],update:[0,1],update_consumer_offset:0,upon:[0,1],usage:[0,5],used:[0,1],user:3,using:6,utf:[0,1,3,8],valid:[0,1],valu:[0,1,3,8],variabl:7,variad:8,version:[0,1,5,7],via:[0,1,3],wait:[0,1,3,8],want:[0,7],water:0,well:5,were:[0,1],wget:6,when:[0,1],whenc:[0,1],where:[0,1],wherea:0,whether:[0,1,3],which:[0,1,2,3],wind:0,without:[0,1],work:3,would:[0,1],write_int_str:0,write_short_str:0,written:[0,8],xerial:0,xerial_blocks:0,xerial_compat:0,xzvf:6,yield:[0,1],you:[0,1,3,7,8],your:6,zookeep:[0,7]},titles:["kafka package","kafka.consumer package","kafka.partitioner package","kafka.producer package","kafka","kafka-python","Install","Tests","Usage"],titleterms:{asynchron:8,base:[1,2,3],bleed:6,client:0,codec:0,common:0,conn:0,consum:[1,8],content:[0,1,2,3,5],context:0,develop:6,edge:6,hash:2,indice:5,instal:6,install:6,integr:7,kafka:[0,1,2,3,4,5],kafkaconsum:8,kei:[3,8],latest:6,level:8,librari:6,licens:5,low:8,messag:8,mode:8,modul:[0,1,2,3,6],multiprocess:[1,8],optional:6,packag:[0,1,2,3],partition:2,produc:3,protocol:0,python:[5,6],releas:6,roundrobin:2,run:7,simpl:[1,3],simpleproduc:8,snappi:6,statu:5,submodul:[0,1,2,3],subpackag:0,subset:7,tabl:5,test:7,unit:7,usage:8,util:0}})