Index

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

_

__call__() (pykafka.partitioners.HashingPartitioner method)
__del__() (pykafka.connection.BrokerConnection method)
(pykafka.simpleconsumer.SimpleConsumer method)
__enter__() (pykafka.handlers.ThreadingHandler.Semaphore method)
(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.FetchRequest method)
(pykafka.protocol.FetchResponse method)
(pykafka.protocol.GroupCoordinatorRequest method)
(pykafka.protocol.GroupCoordinatorResponse 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.FetchRequest method)
(pykafka.protocol.GroupCoordinatorRequest 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.balancedconsumer.BalancedConsumer attribute)
(pykafka.broker.Broker attribute)
(pykafka.client.KafkaClient attribute)
(pykafka.cluster.Cluster attribute)
(pykafka.common.CompressionType 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.handlers.ThreadingHandler.Semaphore attribute)
(pykafka.partition.Partition attribute)
(pykafka.partitioners.BasePartitioner attribute)
(pykafka.producer.Producer attribute)
(pykafka.protocol.MessageSet attribute)
(pykafka.protocol.Request attribute)
(pykafka.protocol.Response attribute)
(pykafka.simpleconsumer.SimpleConsumer attribute)
(pykafka.topic.Topic 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)
_build_watch_callback() (pykafka.balancedconsumer.BalancedConsumer method)
_decide_partitions() (pykafka.balancedconsumer.BalancedConsumer method)
_discover_group_coordinator() (pykafka.simpleconsumer.SimpleConsumer method)
_get_brokers_from_zookeeper() (pykafka.cluster.Cluster method)
_get_compressed() (pykafka.protocol.MessageSet method)
_get_held_partitions() (pykafka.balancedconsumer.BalancedConsumer method)
_get_internal_consumer() (pykafka.balancedconsumer.BalancedConsumer method)
_get_metadata() (pykafka.cluster.Cluster method)
_get_participants() (pykafka.balancedconsumer.BalancedConsumer method)
_get_unique_req_handler() (pykafka.broker.Broker 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)
_request_metadata() (pykafka.cluster.Cluster method)
_send_request() (pykafka.producer.Producer method)
_set_watches() (pykafka.balancedconsumer.BalancedConsumer method)
_setup_autocommit_worker() (pykafka.simpleconsumer.SimpleConsumer 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)
_unpack_message_set() (pykafka.protocol.FetchResponse method)
_update() (pykafka.producer.Producer method)
(pykafka.simpleconsumer.SimpleConsumer method)
_update_brokers() (pykafka.cluster.Cluster method)
_update_member_assignment() (pykafka.balancedconsumer.BalancedConsumer method)
_wait_all() (pykafka.producer.Producer method)
_write_header() (pykafka.protocol.Request method)

A

acquire() (pykafka.handlers.ThreadingHandler.Semaphore method)
add_message() (pykafka.protocol.ProduceRequest method)
add_request() (pykafka.protocol.FetchRequest method)
API_KEY (pykafka.protocol.FetchRequest attribute)
(pykafka.protocol.GroupCoordinatorRequest 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)
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.FetchRequest method)
(pykafka.protocol.GroupCoordinatorRequest 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_delivery_report() (pykafka.producer.Producer method)
get_group_coordinator() (pykafka.cluster.Cluster method)
get_nowait() (pykafka.handlers.ThreadingHandler.Queue method)
get_producer() (pykafka.topic.Topic method)
get_simple_consumer() (pykafka.topic.Topic method)
get_sync_producer() (pykafka.topic.Topic method)
GroupAuthorizationFailed
GroupCoordinatorNotAvailable
GroupCoordinatorRequest (class in pykafka.protocol)
GroupCoordinatorResponse (class in pykafka.protocol)
GroupLoadInProgress

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)
heartbeat() (pykafka.broker.Broker method)
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)
IllegalGeneration
InconsistentGroupProtocol
InvalidMessageError
InvalidMessageSize
InvalidSessionTimeout
isr (pykafka.partition.Partition attribute)

J

join() (pykafka.handlers.ThreadingHandler.Queue method)
join_group() (pykafka.broker.Broker 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
leave_group() (pykafka.broker.Broker method)
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)
NoBrokersAvailableError
NoMessagesConsumedError
NotCoordinatorForGroup
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)
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.balancedconsumer.BalancedConsumer attribute)
(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)

R

raise_error() (in module pykafka.utils.error_handlers)
(pykafka.protocol.Response method)
random_partitioner() (in module pykafka.partitioners)
RdKafkaException
RdKafkaStoppedException
RebalanceInProgress
reconnect() (pykafka.connection.BrokerConnection method)
recvall_into() (in module pykafka.utils.socket)
release() (pykafka.handlers.ThreadingHandler.Semaphore method)
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)
Socket (pykafka.handlers.ThreadingHandler attribute)
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)
sync_group() (pykafka.broker.Broker method)

T

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

U

UnknownError
UnknownMemberId
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)