Index

_ | A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | Z

_

__call__() (pykafka.partitioners.HashingPartitioner method)
__del__() (pykafka.connection.BrokerConnection method)
(pykafka.simpleconsumer.SimpleConsumer method)
__enter__() (pykafka.producer.Producer method)
__exit__() (pykafka.producer.Producer method)
__getnewargs__() (pykafka.handlers.RequestHandler.Shared method)
(pykafka.handlers.RequestHandler.Task method)
__getstate__() (pykafka.handlers.RequestHandler.Shared method)
(pykafka.handlers.RequestHandler.Task method)
__init__() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.broker.Broker method)
(pykafka.client.KafkaClient method)
(pykafka.cluster.Cluster method)
(pykafka.connection.BrokerConnection method)
(pykafka.handlers.RequestHandler method)
(pykafka.handlers.ResponseFuture method)
(pykafka.partition.Partition method)
(pykafka.partitioners.HashingPartitioner method)
(pykafka.producer.Producer method)
(pykafka.protocol.ConsumerMetadataRequest method)
(pykafka.protocol.ConsumerMetadataResponse method)
(pykafka.protocol.FetchRequest method)
(pykafka.protocol.FetchResponse method)
(pykafka.protocol.MessageSet method)
(pykafka.protocol.MetadataRequest method)
(pykafka.protocol.MetadataResponse method)
(pykafka.protocol.OffsetCommitRequest method)
(pykafka.protocol.OffsetCommitResponse method)
(pykafka.protocol.OffsetFetchRequest method)
(pykafka.protocol.OffsetFetchResponse method)
(pykafka.protocol.OffsetRequest method)
(pykafka.protocol.OffsetResponse method)
(pykafka.protocol.ProduceRequest method)
(pykafka.protocol.ProduceResponse method)
(pykafka.simpleconsumer.SimpleConsumer method)
(pykafka.topic.Topic method)
__iter__() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.simpleconsumer.SimpleConsumer method)
__len__() (pykafka.protocol.ConsumerMetadataRequest method)
(pykafka.protocol.FetchRequest method)
(pykafka.protocol.MessageSet method)
(pykafka.protocol.MetadataRequest method)
(pykafka.protocol.OffsetCommitRequest method)
(pykafka.protocol.OffsetFetchRequest method)
(pykafka.protocol.OffsetRequest method)
(pykafka.protocol.ProduceRequest method)
__new__() (pykafka.handlers.RequestHandler.Shared static method)
(pykafka.handlers.RequestHandler.Task static method)
__repr__() (pykafka.handlers.RequestHandler.Shared method)
(pykafka.handlers.RequestHandler.Task method)
__weakref__ (pykafka.client.KafkaClient attribute)
(pykafka.cluster.Cluster attribute)
(pykafka.common.CompressionType attribute)
(pykafka.common.Message attribute)
(pykafka.common.OffsetType attribute)
(pykafka.connection.BrokerConnection attribute)
(pykafka.exceptions.KafkaException attribute)
(pykafka.handlers.Handler attribute)
(pykafka.handlers.RequestHandler attribute)
(pykafka.handlers.ResponseFuture attribute)
(pykafka.partitioners.BasePartitioner attribute)
(pykafka.producer.Producer attribute)
(pykafka.protocol.Response attribute)
_add_partitions() (pykafka.balancedconsumer.BalancedConsumer method)
_add_self() (pykafka.balancedconsumer.BalancedConsumer method)
_asdict() (pykafka.handlers.RequestHandler.Shared method)
(pykafka.handlers.RequestHandler.Task method)
_auto_commit() (pykafka.simpleconsumer.SimpleConsumer method)
_build_default_error_handlers() (pykafka.simpleconsumer.SimpleConsumer method)
_check_held_partitions() (pykafka.balancedconsumer.BalancedConsumer method)
_decide_partitions() (pykafka.balancedconsumer.BalancedConsumer method)
_discover_offset_manager() (pykafka.simpleconsumer.SimpleConsumer method)
_get_compressed() (pykafka.protocol.MessageSet method)
_get_held_partitions() (pykafka.balancedconsumer.BalancedConsumer method)
_get_metadata() (pykafka.cluster.Cluster method)
_get_participants() (pykafka.balancedconsumer.BalancedConsumer method)
_get_zk_state_listener() (pykafka.balancedconsumer.BalancedConsumer method)
_make() (pykafka.handlers.RequestHandler.Shared class method)
(pykafka.handlers.RequestHandler.Task class method)
_partitions (pykafka.balancedconsumer.BalancedConsumer attribute)
_path_from_partition() (pykafka.balancedconsumer.BalancedConsumer method)
_path_self (pykafka.balancedconsumer.BalancedConsumer attribute)
_produce() (pykafka.producer.Producer method)
_raise_worker_exceptions() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.producer.Producer method)
(pykafka.simpleconsumer.SimpleConsumer method)
_rebalance() (pykafka.balancedconsumer.BalancedConsumer method)
_remove_partitions() (pykafka.balancedconsumer.BalancedConsumer method)
_replace() (pykafka.handlers.RequestHandler.Shared method)
(pykafka.handlers.RequestHandler.Task method)
_send_request() (pykafka.producer.Producer method)
_set_watches() (pykafka.balancedconsumer.BalancedConsumer method)
_setup_autocommit_worker() (pykafka.simpleconsumer.SimpleConsumer method)
_setup_checker_worker() (pykafka.balancedconsumer.BalancedConsumer method)
_setup_fetch_workers() (pykafka.simpleconsumer.SimpleConsumer method)
_setup_internal_consumer() (pykafka.balancedconsumer.BalancedConsumer method)
_setup_owned_brokers() (pykafka.producer.Producer method)
_setup_zookeeper() (pykafka.balancedconsumer.BalancedConsumer method)
_start_thread() (pykafka.handlers.RequestHandler method)
_suspend_internal_consumer() (pykafka.balancedconsumer.BalancedConsumer method)
_unpack_message_set() (pykafka.protocol.FetchResponse method)
_update() (pykafka.producer.Producer method)
(pykafka.simpleconsumer.SimpleConsumer method)
_update_brokers() (pykafka.cluster.Cluster method)
_wait_all() (pykafka.producer.Producer method)
_write_header() (pykafka.protocol.Request method)

A

add_message() (pykafka.protocol.ProduceRequest method)
add_request() (pykafka.protocol.FetchRequest method)
API_KEY (pykafka.protocol.ConsumerMetadataRequest attribute)
(pykafka.protocol.FetchRequest attribute)
(pykafka.protocol.MetadataRequest attribute)
(pykafka.protocol.OffsetCommitRequest attribute)
(pykafka.protocol.OffsetFetchRequest attribute)
(pykafka.protocol.OffsetRequest attribute)
(pykafka.protocol.ProduceRequest attribute)
API_KEY() (pykafka.protocol.Request method)

B

BalancedConsumer (class in pykafka.balancedconsumer)
BasePartitioner (class in pykafka.partitioners)
Broker (class in pykafka.broker)
BrokerConnection (class in pykafka.connection)
brokers (pykafka.cluster.Cluster attribute)

C

Cluster (class in pykafka.cluster)
commit_consumer_group_offsets() (pykafka.broker.Broker method)
commit_offsets() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.simpleconsumer.SimpleConsumer method)
CompressionType (class in pykafka.common)
connect() (pykafka.broker.Broker method)
(pykafka.connection.BrokerConnection method)
connect_offsets_channel() (pykafka.broker.Broker method)
connected (pykafka.broker.Broker attribute)
(pykafka.connection.BrokerConnection attribute)
connection (pykafka.handlers.RequestHandler.Shared attribute)
consume() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.simpleconsumer.SimpleConsumer method)
ConsumerCoordinatorNotAvailable
ConsumerMetadataRequest (class in pykafka.protocol)
ConsumerMetadataResponse (class in pykafka.protocol)
ConsumerStoppedException

D

decode() (pykafka.protocol.MessageSet class method)
decode_gzip() (in module pykafka.utils.compression)
decode_snappy() (in module pykafka.utils.compression)
disconnect() (pykafka.connection.BrokerConnection method)

E

earliest_available_offset() (pykafka.partition.Partition method)
earliest_available_offsets() (pykafka.topic.Topic method)
empty() (pykafka.handlers.ThreadingHandler.Queue method)
encode_gzip() (in module pykafka.utils.compression)
encode_snappy() (in module pykafka.utils.compression)
ending (pykafka.handlers.RequestHandler.Shared attribute)
Event() (pykafka.handlers.ThreadingHandler method)

F

fetch() (pykafka.simpleconsumer.SimpleConsumer method)
fetch_consumer_group_offsets() (pykafka.broker.Broker method)
fetch_messages() (pykafka.broker.Broker method)
fetch_offset_limit() (pykafka.partition.Partition method)
fetch_offset_limits() (pykafka.topic.Topic method)
fetch_offsets() (pykafka.simpleconsumer.SimpleConsumer method)
FetchRequest (class in pykafka.protocol)
FetchResponse (class in pykafka.protocol)
from_metadata() (pykafka.broker.Broker class method)
full() (pykafka.handlers.ThreadingHandler.Queue method)
future (pykafka.handlers.RequestHandler.Task attribute)

G

get() (pykafka.handlers.ResponseFuture method)
(pykafka.handlers.ThreadingHandler.Queue method)
get_balanced_consumer() (pykafka.topic.Topic method)
get_bytes() (pykafka.protocol.ConsumerMetadataRequest method)
(pykafka.protocol.FetchRequest method)
(pykafka.protocol.MetadataRequest method)
(pykafka.protocol.OffsetCommitRequest method)
(pykafka.protocol.OffsetFetchRequest method)
(pykafka.protocol.OffsetRequest method)
(pykafka.protocol.ProduceRequest method)
(pykafka.protocol.Request method)
get_nowait() (pykafka.handlers.ThreadingHandler.Queue method)
get_offset_manager() (pykafka.cluster.Cluster method)
get_producer() (pykafka.topic.Topic method)
get_simple_consumer() (pykafka.topic.Topic method)
get_sync_producer() (pykafka.topic.Topic method)

H

handle_partition_responses() (in module pykafka.utils.error_handlers)
Handler (class in pykafka.handlers)
handler (pykafka.broker.Broker attribute)
(pykafka.cluster.Cluster attribute)
HashingPartitioner (class in pykafka.partitioners)
held_offsets (pykafka.balancedconsumer.BalancedConsumer attribute)
(pykafka.simpleconsumer.SimpleConsumer attribute)
host (pykafka.broker.Broker attribute)

I

id (pykafka.broker.Broker attribute)
(pykafka.partition.Partition attribute)
InvalidMessageError
InvalidMessageSize
isr (pykafka.partition.Partition attribute)

J

join() (pykafka.handlers.ThreadingHandler.Queue method)

K

KafkaClient (class in pykafka.client)
KafkaException

L

latest_available_offset() (pykafka.partition.Partition method)
latest_available_offsets() (pykafka.topic.Topic method)
leader (pykafka.partition.Partition attribute)
LeaderNotAvailable
Lock() (pykafka.handlers.ThreadingHandler method)

M

Message (class in pykafka.common)
(class in pykafka.protocol)
message_count() (pykafka.protocol.ProduceRequest method)
messages (pykafka.protocol.ProduceRequest attribute)
MessageSet (class in pykafka.protocol)
MessageSizeTooLarge
MetadataRequest (class in pykafka.protocol)
MetadataResponse (class in pykafka.protocol)

N

name (pykafka.topic.Topic attribute)
NoMessagesConsumedError
NotCoordinatorForConsumer
NotLeaderForPartition

O

OffsetCommitRequest (class in pykafka.protocol)
OffsetCommitResponse (class in pykafka.protocol)
OffsetFetchRequest (class in pykafka.protocol)
OffsetFetchResponse (class in pykafka.protocol)
OffsetMetadataTooLarge
OffsetOutOfRangeError
OffsetRequest (class in pykafka.protocol)
OffsetRequestFailedError
OffsetResponse (class in pykafka.protocol)
offsets_channel_connected (pykafka.broker.Broker attribute)
offsets_channel_handler (pykafka.broker.Broker attribute)
OffsetsLoadInProgress
OffsetType (class in pykafka.common)

P

pack_into() (pykafka.protocol.Message method)
(pykafka.protocol.MessageSet method)
Partition (class in pykafka.partition)
PartitionFetchRequest (class in pykafka.protocol)
PartitionOffsetCommitRequest (class in pykafka.protocol)
PartitionOffsetFetchRequest (class in pykafka.protocol)
PartitionOffsetRequest (class in pykafka.protocol)
PartitionOwnedError
partitions (pykafka.simpleconsumer.SimpleConsumer attribute)
(pykafka.topic.Topic attribute)
port (pykafka.broker.Broker attribute)
produce() (pykafka.producer.Producer method)
produce_messages() (pykafka.broker.Broker method)
ProduceFailureError
Producer (class in pykafka.producer)
ProduceRequest (class in pykafka.protocol)
ProduceResponse (class in pykafka.protocol)
ProducerQueueFullError
ProducerStoppedException
ProtocolClientError
put() (pykafka.handlers.ThreadingHandler.Queue method)
put_nowait() (pykafka.handlers.ThreadingHandler.Queue method)
pykafka.balancedconsumer (module)
pykafka.broker (module)
pykafka.client (module)
pykafka.cluster (module)
pykafka.common (module)
pykafka.connection (module)
pykafka.exceptions (module)
pykafka.handlers (module)
pykafka.partition (module)
pykafka.partitioners (module)
pykafka.producer (module)
pykafka.protocol (module)
pykafka.simpleconsumer (module)
pykafka.topic (module)
pykafka.utils.compression (module)
pykafka.utils.error_handlers (module)
pykafka.utils.socket (module)
pykafka.utils.struct_helpers (module)

Q

qsize() (pykafka.handlers.ThreadingHandler.Queue method)
QueueEmptyError (pykafka.handlers.ThreadingHandler attribute)

R

raise_error() (in module pykafka.utils.error_handlers)
(pykafka.protocol.Response method)
random_partitioner() (in module pykafka.partitioners)
reconnect() (pykafka.connection.BrokerConnection method)
recvall_into() (in module pykafka.utils.socket)
replicas (pykafka.partition.Partition attribute)
Request (class in pykafka.protocol)
request (pykafka.handlers.RequestHandler.Task attribute)
request() (pykafka.connection.BrokerConnection method)
(pykafka.handlers.RequestHandler method)
request_metadata() (pykafka.broker.Broker method)
request_offset_limits() (pykafka.broker.Broker method)
RequestHandler (class in pykafka.handlers)
RequestHandler.Shared (class in pykafka.handlers)
RequestHandler.Task (class in pykafka.handlers)
requests (pykafka.handlers.RequestHandler.Shared attribute)
RequestTimedOut
reset_offsets() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.simpleconsumer.SimpleConsumer method)
Response (class in pykafka.protocol)
response() (pykafka.connection.BrokerConnection method)
ResponseFuture (class in pykafka.handlers)

S

set_error() (pykafka.handlers.ResponseFuture method)
set_response() (pykafka.handlers.ResponseFuture method)
SimpleConsumer (class in pykafka.simpleconsumer)
SocketDisconnectedError
spawn() (pykafka.handlers.Handler method)
start() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.handlers.RequestHandler method)
(pykafka.producer.Producer method)
(pykafka.simpleconsumer.SimpleConsumer method)
stop() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.handlers.RequestHandler method)
(pykafka.producer.Producer method)
(pykafka.simpleconsumer.SimpleConsumer method)

T

task_done() (pykafka.handlers.ThreadingHandler.Queue method)
ThreadingHandler (class in pykafka.handlers)
ThreadingHandler.Queue (class in pykafka.handlers)
Topic (class in pykafka.topic)
topic (pykafka.partition.Partition attribute)
(pykafka.simpleconsumer.SimpleConsumer attribute)
topics (pykafka.cluster.Cluster attribute)

U

UnknownError
UnknownTopicOrPartition
unpack_from() (in module pykafka.utils.struct_helpers)
update() (pykafka.cluster.Cluster method)
(pykafka.partition.Partition method)
(pykafka.topic.Topic method)
update_cluster() (pykafka.client.KafkaClient method)

Z

ZookeeperConnectionLost