Index

_

__enter__() (kafka.consumer.simple.FetchContext method) (kafka.context.OffsetCommitContext method) __exit__() (kafka.consumer.simple.FetchContext method) (kafka.context.OffsetCommitContext method) __getnewargs__() (kafka.common.BrokerMetadata method) (kafka.common.FetchRequest method) (kafka.common.FetchResponse method) (kafka.common.KafkaMessage method) (kafka.common.Message method) (kafka.common.MetadataRequest method) (kafka.common.MetadataResponse method) (kafka.common.OffsetAndMessage method) (kafka.common.OffsetCommitRequest method) (kafka.common.OffsetCommitResponse method) (kafka.common.OffsetFetchRequest method) (kafka.common.OffsetFetchResponse method) (kafka.common.OffsetRequest method) (kafka.common.OffsetResponse method) (kafka.common.PartitionMetadata method) (kafka.common.ProduceRequest method) (kafka.common.ProduceResponse method) (kafka.common.TopicAndPartition method) (kafka.common.TopicMetadata method) (kafka.consumer.kafka.OffsetsStruct method) __getstate__() (kafka.common.BrokerMetadata method) (kafka.common.FetchRequest method) (kafka.common.FetchResponse method) (kafka.common.KafkaMessage method) (kafka.common.Message method) (kafka.common.MetadataRequest method) (kafka.common.MetadataResponse method) (kafka.common.OffsetAndMessage method) (kafka.common.OffsetCommitRequest method) (kafka.common.OffsetCommitResponse method) (kafka.common.OffsetFetchRequest method) (kafka.common.OffsetFetchResponse method) (kafka.common.OffsetRequest method) (kafka.common.OffsetResponse method) (kafka.common.PartitionMetadata method) (kafka.common.ProduceRequest method) (kafka.common.ProduceResponse method) (kafka.common.TopicAndPartition method) (kafka.common.TopicMetadata method) (kafka.consumer.kafka.OffsetsStruct method)

__iter__() (kafka.consumer.multiprocess.MultiProcessConsumer method) __nonzero__() (kafka.context.OffsetCommitContext method) __repr__() (kafka.common.BrokerMetadata method) (kafka.common.FetchRequest method) (kafka.common.FetchResponse method) (kafka.common.KafkaMessage method) (kafka.common.Message method) (kafka.common.MetadataRequest method) (kafka.common.MetadataResponse method) (kafka.common.OffsetAndMessage method) (kafka.common.OffsetCommitRequest method) (kafka.common.OffsetCommitResponse method) (kafka.common.OffsetFetchRequest method) (kafka.common.OffsetFetchResponse method) (kafka.common.OffsetRequest method) (kafka.common.OffsetResponse method) (kafka.common.PartitionMetadata method) (kafka.common.ProduceRequest method) (kafka.common.ProduceResponse method) (kafka.common.TopicAndPartition method) (kafka.common.TopicMetadata method) (kafka.consumer.kafka.OffsetsStruct method)

A

attributes (kafka.common.Message attribute)

B

BrokerMetadata (class in kafka.common)

brokers (kafka.common.MetadataResponse attribute)

C

close() (kafka.conn.KafkaConnection method) collect_hosts() (in module kafka.conn) commit (kafka.consumer.kafka.OffsetsStruct attribute) commit() (kafka.consumer.base.Consumer method) (kafka.consumer.kafka.KafkaConsumer method) (kafka.context.OffsetCommitContext method) commit_partition_offsets() (kafka.context.OffsetCommitContext method) configure() (kafka.consumer.kafka.KafkaConsumer method)

Consumer (class in kafka.consumer.base) copy() (kafka.conn.KafkaConnection method) create_gzip_message() (in module kafka.protocol) create_message() (in module kafka.protocol) create_message_set() (in module kafka.protocol) create_snappy_message() (in module kafka.protocol)

D

decode_fetch_response() (kafka.protocol.KafkaProtocol class method) decode_metadata_response() (kafka.protocol.KafkaProtocol class method) decode_offset_commit_response() (kafka.protocol.KafkaProtocol class method)

decode_offset_fetch_response() (kafka.protocol.KafkaProtocol class method) decode_offset_response() (kafka.protocol.KafkaProtocol class method) decode_produce_response() (kafka.protocol.KafkaProtocol class method)

E

encode_fetch_request() (kafka.protocol.KafkaProtocol class method) encode_metadata_request() (kafka.protocol.KafkaProtocol class method) encode_offset_commit_request() (kafka.protocol.KafkaProtocol class method)

encode_offset_fetch_request() (kafka.protocol.KafkaProtocol class method) encode_produce_request() (kafka.protocol.KafkaProtocol class method) error (kafka.common.FetchResponse attribute) (kafka.common.OffsetCommitResponse attribute) (kafka.common.OffsetFetchResponse attribute) (kafka.common.OffsetResponse attribute) (kafka.common.PartitionMetadata attribute) (kafka.common.ProduceResponse attribute) (kafka.common.TopicMetadata attribute)

F

fetch (kafka.consumer.kafka.OffsetsStruct attribute) fetch_messages() (kafka.consumer.kafka.KafkaConsumer method) FetchContext (class in kafka.consumer.simple)

FetchRequest (class in kafka.common) FetchResponse (class in kafka.common)

G

get_messages() (kafka.consumer.multiprocess.MultiProcessConsumer method) (kafka.consumer.simple.SimpleConsumer method)

get_partition_offsets() (kafka.consumer.kafka.KafkaConsumer method)

H

handle_out_of_range() (kafka.context.OffsetCommitContext method) HashedPartitioner (class in kafka.partitioner.hashed) highwater (kafka.consumer.kafka.OffsetsStruct attribute)

highwaterMark (kafka.common.FetchResponse attribute) host (kafka.common.BrokerMetadata attribute)

I

isr (kafka.common.PartitionMetadata attribute)

K

kafka.client (module) kafka.codec (module) kafka.common (module) kafka.conn (module) kafka.consumer.base (module) kafka.consumer.kafka (module) kafka.consumer.multiprocess (module) kafka.consumer.simple (module) kafka.context (module) kafka.partitioner.base (module) kafka.partitioner.hashed (module) kafka.partitioner.roundrobin (module)

kafka.producer.base (module) kafka.producer.keyed (module) kafka.producer.simple (module) kafka.protocol (module) kafka.util (module) kafka_bytestring() (in module kafka.util) KafkaConnection (class in kafka.conn) KafkaConsumer (class in kafka.consumer.kafka) KafkaMessage (class in kafka.common) KafkaProtocol (class in kafka.protocol) key (kafka.common.KafkaMessage attribute) (kafka.common.Message attribute) KeyedProducer (class in kafka.producer.keyed)

L

leader (kafka.common.PartitionMetadata attribute)

M

magic (kafka.common.Message attribute) mark() (kafka.context.OffsetCommitContext method) max_bytes (kafka.common.FetchRequest attribute) max_offsets (kafka.common.OffsetRequest attribute) Message (class in kafka.common) message (kafka.common.OffsetAndMessage attribute)

messages (kafka.common.FetchResponse attribute) (kafka.common.ProduceRequest attribute) metadata (kafka.common.OffsetCommitRequest attribute) (kafka.common.OffsetFetchResponse attribute) MetadataRequest (class in kafka.common) MetadataResponse (class in kafka.common) MultiProcessConsumer (class in kafka.consumer.multiprocess)

N

next() (kafka.consumer.kafka.KafkaConsumer method)

nodeId (kafka.common.BrokerMetadata attribute)

O

offset (kafka.common.FetchRequest attribute) (kafka.common.KafkaMessage attribute) (kafka.common.OffsetAndMessage attribute) (kafka.common.OffsetCommitRequest attribute) (kafka.common.OffsetFetchResponse attribute) (kafka.common.ProduceResponse attribute) OffsetAndMessage (class in kafka.common) OffsetCommitContext (class in kafka.context) OffsetCommitRequest (class in kafka.common) OffsetCommitResponse (class in kafka.common) OffsetFetchRequest (class in kafka.common)

OffsetFetchResponse (class in kafka.common) OffsetRequest (class in kafka.common) OffsetResponse (class in kafka.common) offsets (kafka.common.OffsetResponse attribute) offsets() (kafka.consumer.kafka.KafkaConsumer method) OffsetsStruct (class in kafka.consumer.kafka)

P

partition (kafka.common.FetchRequest attribute) (kafka.common.FetchResponse attribute) (kafka.common.KafkaMessage attribute) (kafka.common.OffsetCommitRequest attribute) (kafka.common.OffsetCommitResponse attribute) (kafka.common.OffsetFetchRequest attribute) (kafka.common.OffsetFetchResponse attribute) (kafka.common.OffsetRequest attribute) (kafka.common.OffsetResponse attribute) (kafka.common.PartitionMetadata attribute) (kafka.common.ProduceRequest attribute) (kafka.common.ProduceResponse attribute) (kafka.common.TopicAndPartition attribute) partition() (kafka.partitioner.base.Partitioner method) Partitioner (class in kafka.partitioner.base) PartitionMetadata (class in kafka.common) partitions (kafka.common.TopicMetadata attribute) pending() (kafka.consumer.base.Consumer method)

port (kafka.common.BrokerMetadata attribute) Producer (class in kafka.producer.base) ProduceRequest (class in kafka.common) ProduceResponse (class in kafka.common) provide_partition_info() (kafka.consumer.simple.SimpleConsumer method)

R

recv() (kafka.conn.KafkaConnection method) ReentrantTimer (class in kafka.util) reinit() (kafka.conn.KafkaConnection method)

replicas (kafka.common.PartitionMetadata attribute) rollback() (kafka.context.OffsetCommitContext method) RoundRobinPartitioner (class in kafka.partitioner.roundrobin)

S

seek() (kafka.consumer.simple.SimpleConsumer method) send() (kafka.conn.KafkaConnection method) send_messages() (kafka.producer.base.Producer method) set_topic_partitions() (kafka.consumer.kafka.KafkaConsumer method)

SimpleConsumer (class in kafka.consumer.simple) SimpleProducer (class in kafka.producer.simple) snappy_encode() (in module kafka.codec) stop() (kafka.producer.base.Producer method)

T

task_done (kafka.consumer.kafka.OffsetsStruct attribute) task_done() (kafka.consumer.kafka.KafkaConsumer method) time (kafka.common.OffsetRequest attribute) topic (kafka.common.FetchRequest attribute) (kafka.common.FetchResponse attribute) (kafka.common.KafkaMessage attribute) (kafka.common.OffsetCommitRequest attribute) (kafka.common.OffsetCommitResponse attribute) (kafka.common.OffsetFetchRequest attribute) (kafka.common.OffsetFetchResponse attribute) (kafka.common.OffsetRequest attribute) (kafka.common.OffsetResponse attribute) (kafka.common.PartitionMetadata attribute) (kafka.common.ProduceRequest attribute) (kafka.common.ProduceResponse attribute) (kafka.common.TopicAndPartition attribute) (kafka.common.TopicMetadata attribute)

TopicAndPartition (class in kafka.common) TopicMetadata (class in kafka.common) topics (kafka.common.MetadataRequest attribute) (kafka.common.MetadataResponse attribute)

U

update_consumer_offsets() (kafka.context.OffsetCommitContext method)

V

value (kafka.common.KafkaMessage attribute) (kafka.common.Message attribute)