Index

A

ACK_AFTER_CLUSTER_COMMIT (kafka.producer.base.Producer attribute) ACK_AFTER_LOCAL_WRITE (kafka.producer.base.Producer attribute) ACK_NOT_REQUIRED (kafka.producer.base.Producer attribute)

AsyncProducerQueueFull attributes (kafka.common.Message attribute)

B

backoff_ms (kafka.common.RetryOptions attribute) BrokerMetadata (class in kafka.common) BrokerNotAvailableError

BrokerResponseError brokers (kafka.common.MetadataResponse attribute) BufferUnderflowError

C

check_error() (in module kafka.common) ChecksumError CLIENT_ID (kafka.client.KafkaClient attribute) (kafka.KafkaClient attribute) close() (kafka.client.KafkaClient method) (kafka.KafkaClient method) (kafka.KafkaConnection method) (kafka.KafkaConsumer method) (kafka.conn.KafkaConnection method) (kafka.consumer.KafkaConsumer method) (kafka.consumer.kafka.KafkaConsumer method) collect_hosts() (in module kafka.conn) commit (kafka.consumer.kafka.OffsetsStruct attribute) commit() (kafka.consumer.base.Consumer method) (kafka.KafkaConsumer method) (kafka.consumer.KafkaConsumer method) (kafka.consumer.kafka.KafkaConsumer method) (kafka.context.OffsetCommitContext method) commit_partition_offsets() (kafka.context.OffsetCommitContext method) configure() (kafka.consumer.kafka.KafkaConsumer method) (kafka.KafkaConsumer method) (kafka.consumer.KafkaConsumer method) ConnectionError Consumer (class in kafka.consumer.base) CONSUMER_METADATA_KEY (kafka.protocol.KafkaProtocol attribute)

ConsumerCoordinatorNotAvailableCode ConsumerFetchSizeTooSmall ConsumerMetadataRequest (class in kafka.common) ConsumerMetadataResponse (class in kafka.common) ConsumerNoMoreData ConsumerTimeout copy() (kafka.client.KafkaClient method) (kafka.KafkaClient method) (kafka.KafkaConnection method) (kafka.conn.KafkaConnection method) crc32() (in module kafka.util) create_gzip_message() (in module kafka) (in module kafka.protocol) create_message() (in module kafka) (in module kafka.protocol) create_message_set() (in module kafka.protocol) create_snappy_message() (in module kafka) (in module kafka.protocol)

D

decode_consumer_metadata_response() (kafka.protocol.KafkaProtocol class method) 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) DEFAULT_ACK_TIMEOUT (kafka.producer.base.Producer attribute) DEFAULT_CONFIG (kafka.consumer.kafka.KafkaConsumer attribute) (kafka.KafkaConsumer attribute) (kafka.consumer.KafkaConsumer attribute)

E

encode_consumer_metadata_request() (kafka.protocol.KafkaProtocol class method) 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_offset_request() (kafka.protocol.KafkaProtocol class method)

encode_produce_request() (kafka.protocol.KafkaProtocol class method) ensure_topic_exists() (kafka.client.KafkaClient method) (kafka.KafkaClient method) errno (kafka.common.BrokerNotAvailableError attribute) (kafka.common.ConsumerCoordinatorNotAvailableCode attribute) (kafka.common.InvalidFetchRequestError attribute) (kafka.common.InvalidMessageError attribute) (kafka.common.LeaderNotAvailableError attribute) (kafka.common.MessageSizeTooLargeError attribute) (kafka.common.NotCoordinatorForConsumerCode attribute) (kafka.common.NotLeaderForPartitionError attribute) (kafka.common.OffsetMetadataTooLargeError attribute) (kafka.common.OffsetOutOfRangeError attribute) (kafka.common.OffsetsLoadInProgressCode attribute) (kafka.common.ReplicaNotAvailableError attribute) (kafka.common.RequestTimedOutError attribute) (kafka.common.StaleControllerEpochError attribute) (kafka.common.StaleLeaderEpochCodeError attribute) (kafka.common.UnknownError attribute) (kafka.common.UnknownTopicOrPartitionError attribute) error (kafka.common.ConsumerMetadataResponse attribute) (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) Events (class in kafka.consumer.multiprocess) exit (kafka.consumer.multiprocess.Events attribute)

F

FailedPayloadsError fetch (kafka.consumer.kafka.OffsetsStruct attribute) FETCH_KEY (kafka.protocol.KafkaProtocol attribute) fetch_last_known_offsets() (kafka.consumer.base.Consumer method)

fetch_messages() (kafka.consumer.kafka.KafkaConsumer method) (kafka.KafkaConsumer method) (kafka.consumer.KafkaConsumer method) FetchContext (class in kafka.consumer.simple) FetchRequest (class in kafka.common) FetchResponse (class in kafka.common)

G

get_connected_socket() (kafka.conn.KafkaConnection method) (kafka.KafkaConnection method) get_message() (kafka.consumer.simple.SimpleConsumer method) (kafka.SimpleConsumer method) (kafka.consumer.SimpleConsumer method) get_messages() (kafka.consumer.multiprocess.MultiProcessConsumer method) (kafka.MultiProcessConsumer method) (kafka.SimpleConsumer method) (kafka.consumer.MultiProcessConsumer method) (kafka.consumer.SimpleConsumer method) (kafka.consumer.simple.SimpleConsumer method) get_partition_ids_for_topic() (kafka.client.KafkaClient method) (kafka.KafkaClient method) get_partition_offsets() (kafka.consumer.kafka.KafkaConsumer method) (kafka.KafkaConsumer method) (kafka.consumer.KafkaConsumer method)

group_by_topic_and_partition() (in module kafka.util) groups (kafka.common.ConsumerMetadataRequest attribute) gzip_decode() (in module kafka.codec) gzip_encode() (in module kafka.codec)

H

handle_out_of_range() (kafka.context.OffsetCommitContext method) has_gzip() (in module kafka.codec) has_metadata_for_topic() (kafka.client.KafkaClient method) (kafka.KafkaClient method) has_snappy() (in module kafka.codec)

HashedPartitioner (in module kafka) (in module kafka.partitioner) (in module kafka.partitioner.hashed) highwater (kafka.consumer.kafka.OffsetsStruct attribute) highwaterMark (kafka.common.FetchResponse attribute) host (kafka.common.BrokerMetadata attribute) (kafka.common.ConsumerMetadataResponse attribute)

I

InvalidFetchRequestError InvalidMessageError

isr (kafka.common.PartitionMetadata attribute)

K

kafka (module) kafka.client (module) kafka.codec (module) kafka.common (module) kafka.conn (module) kafka.consumer (module) kafka.consumer.base (module) kafka.consumer.kafka (module) kafka.consumer.multiprocess (module) kafka.consumer.simple (module) kafka.context (module) kafka.partitioner (module) kafka.partitioner.base (module) kafka.partitioner.hashed (module) kafka.partitioner.roundrobin (module) kafka.producer (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) KafkaClient (class in kafka) (class in kafka.client) KafkaConfigurationError KafkaConnection (class in kafka) (class in kafka.conn) KafkaConsumer (class in kafka) (class in kafka.consumer) (class in kafka.consumer.kafka) KafkaError KafkaMessage (class in kafka.common) KafkaProtocol (class in kafka.protocol) KafkaTimeoutError KafkaUnavailableError key (kafka.common.KafkaMessage attribute) (kafka.common.Message attribute) KeyedProducer (class in kafka) (class in kafka.producer) (class in kafka.producer.keyed)

L

leader (kafka.common.PartitionMetadata attribute) LeaderNotAvailableError LegacyPartitioner (class in kafka.partitioner) (class in kafka.partitioner.hashed)

limit (kafka.common.RetryOptions attribute) load_metadata_for_topics() (kafka.client.KafkaClient method) (kafka.KafkaClient method)

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.BrokerNotAvailableError attribute) (kafka.common.ConsumerCoordinatorNotAvailableCode attribute) (kafka.common.InvalidFetchRequestError attribute) (kafka.common.InvalidMessageError attribute) (kafka.common.LeaderNotAvailableError attribute) (kafka.common.MessageSizeTooLargeError attribute) (kafka.common.NotCoordinatorForConsumerCode attribute) (kafka.common.NotLeaderForPartitionError attribute) (kafka.common.OffsetAndMessage attribute) (kafka.common.OffsetMetadataTooLargeError attribute) (kafka.common.OffsetOutOfRangeError attribute) (kafka.common.OffsetsLoadInProgressCode attribute) (kafka.common.ReplicaNotAvailableError attribute) (kafka.common.RequestTimedOutError attribute) (kafka.common.StaleControllerEpochError attribute) (kafka.common.StaleLeaderEpochCodeError attribute) (kafka.common.UnknownError attribute) (kafka.common.UnknownTopicOrPartitionError attribute) messages (kafka.common.FetchResponse attribute) (kafka.common.ProduceRequest attribute) MessageSizeTooLargeError

metadata (kafka.common.OffsetCommitRequest attribute) (kafka.common.OffsetFetchResponse attribute) METADATA_KEY (kafka.protocol.KafkaProtocol attribute) MetadataRequest (class in kafka.common) MetadataResponse (class in kafka.common) MultiProcessConsumer (class in kafka) (class in kafka.consumer) (class in kafka.consumer.multiprocess) murmur2() (in module kafka.partitioner.hashed) Murmur2Partitioner (class in kafka.partitioner) (class in kafka.partitioner.hashed)

N

next() (kafka.consumer.kafka.KafkaConsumer method) (kafka.KafkaConsumer method) (kafka.consumer.KafkaConsumer method) nodeId (kafka.common.BrokerMetadata attribute) (kafka.common.ConsumerMetadataResponse attribute)

NotCoordinatorForConsumerCode NotLeaderForPartitionError

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) OFFSET_COMMIT_KEY (kafka.protocol.KafkaProtocol attribute) OFFSET_FETCH_KEY (kafka.protocol.KafkaProtocol attribute) OFFSET_KEY (kafka.protocol.KafkaProtocol 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) OffsetMetadataTooLargeError OffsetOutOfRangeError OffsetRequest (class in kafka.common) OffsetResponse (class in kafka.common) offsets (kafka.common.OffsetResponse attribute) offsets() (kafka.consumer.kafka.KafkaConsumer method) (kafka.KafkaConsumer method) (kafka.consumer.KafkaConsumer method) OffsetsLoadInProgressCode 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) (kafka.RoundRobinPartitioner method) (kafka.partitioner.LegacyPartitioner method) (kafka.partitioner.Murmur2Partitioner method) (kafka.partitioner.RoundRobinPartitioner method) (kafka.partitioner.hashed.LegacyPartitioner method) (kafka.partitioner.hashed.Murmur2Partitioner method) (kafka.partitioner.roundrobin.RoundRobinPartitioner method) Partitioner (class in kafka.partitioner.base) PartitionMetadata (class in kafka.common) partitions (kafka.common.TopicMetadata attribute) pause (kafka.consumer.multiprocess.Events attribute) pending() (kafka.consumer.base.Consumer method)

port (kafka.common.BrokerMetadata attribute) (kafka.common.ConsumerMetadataResponse attribute) PRODUCE_KEY (kafka.protocol.KafkaProtocol attribute) Producer (class in kafka.producer.base) ProduceRequest (class in kafka.common) ProduceResponse (class in kafka.common) ProtocolError provide_partition_info() (kafka.consumer.base.Consumer method)

R

read_int_string() (in module kafka.util) read_short_string() (in module kafka.util) recv() (kafka.conn.KafkaConnection method) (kafka.KafkaConnection method) ReentrantTimer (class in kafka.util) reinit() (kafka.client.KafkaClient method) (kafka.KafkaClient method) (kafka.KafkaConnection method) (kafka.conn.KafkaConnection method) relative_unpack() (in module kafka.util) ReplicaNotAvailableError replicas (kafka.common.PartitionMetadata attribute)

RequestTimedOutError reset_all_metadata() (kafka.client.KafkaClient method) (kafka.KafkaClient method) reset_partition_offset() (kafka.consumer.simple.SimpleConsumer method) (kafka.SimpleConsumer method) (kafka.consumer.SimpleConsumer method) reset_topic_metadata() (kafka.client.KafkaClient method) (kafka.KafkaClient method) retry_on_timeouts (kafka.common.RetryOptions attribute) RetryOptions (class in kafka.common) rollback() (kafka.context.OffsetCommitContext method) RoundRobinPartitioner (class in kafka) (class in kafka.partitioner) (class in kafka.partitioner.roundrobin)

S

seek() (kafka.consumer.simple.SimpleConsumer method) (kafka.SimpleConsumer method) (kafka.consumer.SimpleConsumer method) send() (kafka.conn.KafkaConnection method) (kafka.KafkaConnection method) (kafka.KeyedProducer method) (kafka.producer.KeyedProducer method) (kafka.producer.keyed.KeyedProducer method) send_consumer_metadata_request() (kafka.client.KafkaClient method) (kafka.KafkaClient method) send_fetch_request() (kafka.client.KafkaClient method) (kafka.KafkaClient method) send_messages() (kafka.KeyedProducer method) (kafka.SimpleProducer method) (kafka.producer.KeyedProducer method) (kafka.producer.SimpleProducer method) (kafka.producer.base.Producer method) (kafka.producer.keyed.KeyedProducer method) (kafka.producer.simple.SimpleProducer method) send_metadata_request() (kafka.client.KafkaClient method) (kafka.KafkaClient method) send_offset_commit_request() (kafka.client.KafkaClient method) (kafka.KafkaClient method) send_offset_fetch_request() (kafka.client.KafkaClient method) (kafka.KafkaClient method) send_offset_fetch_request_kafka() (kafka.client.KafkaClient method) (kafka.KafkaClient method) send_offset_request() (kafka.client.KafkaClient method) (kafka.KafkaClient method) send_produce_request() (kafka.client.KafkaClient method) (kafka.KafkaClient method)

set_topic_partitions() (kafka.consumer.kafka.KafkaConsumer method) (kafka.KafkaConsumer method) (kafka.consumer.KafkaConsumer method) SimpleConsumer (class in kafka) (class in kafka.consumer) (class in kafka.consumer.simple) SimpleProducer (class in kafka) (class in kafka.producer) (class in kafka.producer.simple) snappy_decode() (in module kafka.codec) snappy_encode() (in module kafka.codec) StaleControllerEpochError StaleLeaderEpochCodeError start (kafka.consumer.multiprocess.Events attribute) start() (kafka.util.ReentrantTimer method) stop() (kafka.consumer.base.Consumer method) (kafka.MultiProcessConsumer method) (kafka.consumer.MultiProcessConsumer method) (kafka.consumer.multiprocess.MultiProcessConsumer method) (kafka.producer.base.Producer method) (kafka.util.ReentrantTimer method)

T

task_done (kafka.consumer.kafka.OffsetsStruct attribute) task_done() (kafka.consumer.kafka.KafkaConsumer method) (kafka.KafkaConsumer method) (kafka.consumer.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.client.KafkaClient attribute) (kafka.KafkaClient attribute) (kafka.common.MetadataRequest attribute) (kafka.common.MetadataResponse attribute)

U

UnknownError UnknownTopicOrPartitionError

UnsupportedCodecError update_consumer_offsets() (kafka.context.OffsetCommitContext method)

V

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

W

write_int_string() (in module kafka.util)

write_short_string() (in module kafka.util)

X

x (in module kafka.common)