pykafka
latest
PyKafka Usage Guide
Consumer Patterns
Producer Patterns
Handling connection loss
pykafka.balancedconsumer
pykafka.broker
pykafka.client
pykafka.cluster
pykafka.common
pykafka.connection
pykafka.exceptions
pykafka.handlers
pykafka.managedbalancedconsumer
pykafka.membershipprotocol
pykafka.partition
pykafka.partitioners
pykafka.producer
pykafka.protocol
pykafka.simpleconsumer
pykafka.topic
pykafka.utils.compression
pykafka.utils.error_handlers
pykafka.utils.socket
pykafka.utils.struct_helpers
pykafka
Docs
»
Index
Edit on GitHub
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
W
_
__call__() (pykafka.partitioners.BasePartitioner method)
(pykafka.partitioners.GroupHashingPartitioner method)
(pykafka.partitioners.HashingPartitioner method)
(pykafka.partitioners.RandomPartitioner method)
__del__() (pykafka.connection.BrokerConnection method)
(pykafka.simpleconsumer.SimpleConsumer method)
__enter__() (pykafka.handlers.ThreadingHandler.Semaphore method)
(pykafka.producer.Producer method)
__eq__() (pykafka.partition.Partition method)
__exit__() (pykafka.producer.Producer method)
__getnewargs__() (pykafka.handlers.RequestHandler.Shared method)
(pykafka.handlers.RequestHandler.Task method)
(pykafka.membershipprotocol.GroupMembershipProtocol method)
(pykafka.protocol.FetchPartitionResponse method)
(pykafka.protocol.OffsetCommitPartitionResponse method)
(pykafka.protocol.OffsetFetchPartitionResponse method)
(pykafka.protocol.ProducePartitionResponse method)
__getstate__() (pykafka.handlers.RequestHandler.Shared method)
(pykafka.handlers.RequestHandler.Task method)
(pykafka.membershipprotocol.GroupMembershipProtocol method)
(pykafka.protocol.FetchPartitionResponse method)
(pykafka.protocol.OffsetCommitPartitionResponse method)
(pykafka.protocol.OffsetFetchPartitionResponse method)
(pykafka.protocol.ProducePartitionResponse method)
__hash__() (pykafka.partition.Partition method)
__init__() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.broker.Broker method)
(pykafka.client.KafkaClient method)
(pykafka.cluster.Cluster method)
(pykafka.connection.BrokerConnection method)
(pykafka.connection.SslConfig method)
(pykafka.exceptions.PartitionOwnedError method)
(pykafka.handlers.RequestHandler method)
(pykafka.handlers.ResponseFuture method)
(pykafka.handlers.ThreadingHandler.Semaphore method)
(pykafka.managedbalancedconsumer.ManagedBalancedConsumer method)
(pykafka.partition.Partition method)
(pykafka.partitioners.GroupHashingPartitioner method)
(pykafka.partitioners.HashingPartitioner method)
(pykafka.partitioners.RandomPartitioner method)
(pykafka.producer.Producer method)
(pykafka.protocol.ApiVersionsResponse method)
(pykafka.protocol.ConsumerGroupProtocolMetadata method)
(pykafka.protocol.CreateTopicsRequest method)
(pykafka.protocol.CreateTopicsResponse method)
(pykafka.protocol.DeleteTopicsRequest method)
(pykafka.protocol.DeleteTopicsResponse method)
(pykafka.protocol.DescribeGroupsRequest method)
(pykafka.protocol.DescribeGroupsResponse method)
(pykafka.protocol.FetchRequest method)
(pykafka.protocol.FetchResponse method)
(pykafka.protocol.FetchResponseV1 method)
(pykafka.protocol.GroupCoordinatorRequest method)
(pykafka.protocol.GroupCoordinatorResponse method)
(pykafka.protocol.HeartbeatRequest method)
(pykafka.protocol.HeartbeatResponse method)
(pykafka.protocol.JoinGroupRequest method)
(pykafka.protocol.JoinGroupResponse method)
(pykafka.protocol.LeaveGroupRequest method)
(pykafka.protocol.LeaveGroupResponse method)
(pykafka.protocol.ListGroupsResponse method)
(pykafka.protocol.ListOffsetRequest method)
(pykafka.protocol.ListOffsetRequestV1 method)
(pykafka.protocol.ListOffsetResponse method)
(pykafka.protocol.ListOffsetResponseV1 method)
(pykafka.protocol.MemberAssignment method)
(pykafka.protocol.Message method)
(pykafka.protocol.MessageSet method)
(pykafka.protocol.MetadataRequest method)
(pykafka.protocol.MetadataRequestV4 method)
(pykafka.protocol.MetadataResponse method)
(pykafka.protocol.MetadataResponseV1 method)
(pykafka.protocol.MetadataResponseV2 method)
(pykafka.protocol.MetadataResponseV3 method)
(pykafka.protocol.MetadataResponseV5 method)
(pykafka.protocol.OffsetCommitRequest method)
(pykafka.protocol.OffsetCommitResponse method)
(pykafka.protocol.OffsetFetchRequest method)
(pykafka.protocol.OffsetFetchResponse method)
(pykafka.protocol.OffsetFetchResponseV2 method)
(pykafka.protocol.ProduceRequest method)
(pykafka.protocol.ProduceResponse method)
(pykafka.protocol.SyncGroupRequest method)
(pykafka.protocol.SyncGroupResponse method)
(pykafka.simpleconsumer.SimpleConsumer method)
(pykafka.topic.Topic method)
__iter__() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.simpleconsumer.SimpleConsumer method)
__len__() (pykafka.protocol.ApiVersionsRequest method)
(pykafka.protocol.CreateTopicsRequest method)
(pykafka.protocol.DeleteTopicsRequest method)
(pykafka.protocol.DescribeGroupsRequest method)
(pykafka.protocol.FetchRequest method)
(pykafka.protocol.GroupCoordinatorRequest method)
(pykafka.protocol.HeartbeatRequest method)
(pykafka.protocol.JoinGroupRequest method)
(pykafka.protocol.LeaveGroupRequest method)
(pykafka.protocol.ListGroupsRequest method)
(pykafka.protocol.ListOffsetRequest method)
(pykafka.protocol.ListOffsetRequestV1 method)
(pykafka.protocol.Message method)
(pykafka.protocol.MessageSet method)
(pykafka.protocol.MetadataRequest method)
(pykafka.protocol.MetadataRequestV4 method)
(pykafka.protocol.OffsetCommitRequest method)
(pykafka.protocol.OffsetFetchRequest method)
(pykafka.protocol.ProduceRequest method)
(pykafka.protocol.SyncGroupRequest method)
__lt__() (pykafka.partition.Partition method)
__ne__() (pykafka.partition.Partition method)
__new__() (pykafka.handlers.RequestHandler.Shared static method)
(pykafka.handlers.RequestHandler.Task static method)
(pykafka.membershipprotocol.GroupMembershipProtocol static method)
(pykafka.protocol.FetchPartitionResponse static method)
(pykafka.protocol.OffsetCommitPartitionResponse static method)
(pykafka.protocol.OffsetFetchPartitionResponse static method)
(pykafka.protocol.ProducePartitionResponse static method)
__repr__() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.broker.Broker method)
(pykafka.client.KafkaClient method)
(pykafka.cluster.Cluster method)
(pykafka.handlers.RequestHandler.Shared method)
(pykafka.handlers.RequestHandler.Task method)
(pykafka.membershipprotocol.GroupMembershipProtocol method)
(pykafka.partition.Partition method)
(pykafka.producer.Producer method)
(pykafka.protocol.FetchPartitionResponse method)
(pykafka.protocol.OffsetCommitPartitionResponse method)
(pykafka.protocol.OffsetFetchPartitionResponse method)
(pykafka.protocol.ProducePartitionResponse method)
(pykafka.simpleconsumer.SimpleConsumer method)
(pykafka.topic.Topic 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.connection.SslConfig attribute)
(pykafka.exceptions.KafkaException attribute)
(pykafka.exceptions.UnicodeException 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.ConsumerGroupProtocolMetadata attribute)
(pykafka.protocol.MemberAssignment attribute)
(pykafka.protocol.MessageSet 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)
(pykafka.membershipprotocol.GroupMembershipProtocol method)
(pykafka.protocol.FetchPartitionResponse method)
(pykafka.protocol.OffsetCommitPartitionResponse method)
(pykafka.protocol.OffsetFetchPartitionResponse method)
(pykafka.protocol.ProducePartitionResponse method)
_auto_commit() (pykafka.simpleconsumer.SimpleConsumer method)
_build_default_error_handlers() (pykafka.managedbalancedconsumer.ManagedBalancedConsumer method)
(pykafka.simpleconsumer.SimpleConsumer method)
_build_watch_callback() (pykafka.balancedconsumer.BalancedConsumer method)
_discover_group_coordinator() (pykafka.simpleconsumer.SimpleConsumer method)
_get_broker_connection_info() (pykafka.cluster.Cluster 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)
_handle_error() (pykafka.managedbalancedconsumer.ManagedBalancedConsumer method)
_join_group() (pykafka.managedbalancedconsumer.ManagedBalancedConsumer method)
_legacy_wrap_socket() (pykafka.connection.SslConfig method)
_make() (pykafka.handlers.RequestHandler.Shared class method)
(pykafka.handlers.RequestHandler.Task class method)
(pykafka.membershipprotocol.GroupMembershipProtocol class method)
(pykafka.protocol.FetchPartitionResponse class method)
(pykafka.protocol.OffsetCommitPartitionResponse class method)
(pykafka.protocol.OffsetFetchPartitionResponse class method)
(pykafka.protocol.ProducePartitionResponse 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)
_produce_has_timed_out() (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)
(pykafka.membershipprotocol.GroupMembershipProtocol method)
(pykafka.protocol.FetchPartitionResponse method)
(pykafka.protocol.OffsetCommitPartitionResponse method)
(pykafka.protocol.OffsetFetchPartitionResponse method)
(pykafka.protocol.ProducePartitionResponse method)
_request_random_broker() (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_heartbeat_worker() (pykafka.managedbalancedconsumer.ManagedBalancedConsumer 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)
_sync_group() (pykafka.managedbalancedconsumer.ManagedBalancedConsumer 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)
(pykafka.managedbalancedconsumer.ManagedBalancedConsumer method)
_wait_all() (pykafka.producer.Producer method)
_wait_for_slot_available() (pykafka.simpleconsumer.SimpleConsumer method)
A
acquire() (pykafka.handlers.ThreadingHandler.Semaphore method)
add_message() (pykafka.protocol.ProduceRequest method)
add_request() (pykafka.protocol.FetchRequest method)
ApiVersionsRequest (class in pykafka.protocol)
ApiVersionsResponse (class in pykafka.protocol)
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)
ConsumerGroupProtocolMetadata (class in pykafka.protocol)
ConsumerStoppedException
CreateTopicRequest (class in pykafka.protocol)
CreateTopicsRequest (class in pykafka.protocol)
CreateTopicsResponse (class in pykafka.protocol)
D
decide_partitions (pykafka.membershipprotocol.GroupMembershipProtocol attribute)
decide_partitions_range() (in module pykafka.membershipprotocol)
decide_partitions_roundrobin() (in module pykafka.membershipprotocol)
decode() (pykafka.protocol.MessageSet class method)
decode_gzip() (in module pykafka.utils.compression)
decode_lz4_old_kafka() (in module pykafka.utils.compression)
decode_snappy() (in module pykafka.utils.compression)
DeleteTopicsRequest (class in pykafka.protocol)
DeleteTopicsResponse (class in pykafka.protocol)
DescribeGroupsRequest (class in pykafka.protocol)
DescribeGroupsResponse (class in pykafka.protocol)
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_lz4_old_kafka() (in module pykafka.utils.compression)
encode_snappy() (in module pykafka.utils.compression)
ending (pykafka.handlers.RequestHandler.Shared attribute)
err (pykafka.protocol.FetchPartitionResponse attribute)
(pykafka.protocol.OffsetCommitPartitionResponse attribute)
(pykafka.protocol.OffsetFetchPartitionResponse attribute)
(pykafka.protocol.ProducePartitionResponse attribute)
Event() (pykafka.handlers.ThreadingHandler method)
F
fetch() (pykafka.simpleconsumer.SimpleConsumer method)
fetch_api_versions() (pykafka.cluster.Cluster method)
fetch_consumer_group_offsets() (pykafka.broker.Broker method)
fetch_offset_limit() (pykafka.partition.Partition method)
fetch_offset_limits() (pykafka.topic.Topic method)
fetch_offsets() (pykafka.simpleconsumer.SimpleConsumer method)
FetchPartitionResponse (class in pykafka.protocol)
FetchRequest (class in pykafka.protocol)
FetchResponse (class in pykafka.protocol)
FetchResponseV1 (class in pykafka.protocol)
FetchResponseV2 (class in pykafka.protocol)
from_metadata() (pykafka.broker.Broker class method)
full() (pykafka.handlers.ThreadingHandler.Queue method)
future (pykafka.handlers.RequestHandler.Task attribute)
G
GaiError (pykafka.handlers.ThreadingHandler attribute)
get() (pykafka.handlers.ResponseFuture method)
(pykafka.handlers.ThreadingHandler.Queue method)
get_balanced_consumer() (pykafka.topic.Topic method)
get_bytes() (pykafka.protocol.ApiVersionsRequest method)
(pykafka.protocol.CreateTopicsRequest method)
(pykafka.protocol.DeleteTopicsRequest method)
(pykafka.protocol.DescribeGroupsRequest method)
(pykafka.protocol.FetchRequest method)
(pykafka.protocol.GroupCoordinatorRequest method)
(pykafka.protocol.HeartbeatRequest method)
(pykafka.protocol.JoinGroupRequest method)
(pykafka.protocol.LeaveGroupRequest method)
(pykafka.protocol.ListGroupsRequest method)
(pykafka.protocol.ListOffsetRequest method)
(pykafka.protocol.ListOffsetRequestV1 method)
(pykafka.protocol.MetadataRequest method)
(pykafka.protocol.MetadataRequestV4 method)
(pykafka.protocol.OffsetCommitRequest method)
(pykafka.protocol.OffsetFetchRequest method)
(pykafka.protocol.ProduceRequest method)
(pykafka.protocol.SyncGroupRequest method)
get_delivery_report() (pykafka.producer.Producer method)
get_group_coordinator() (pykafka.cluster.Cluster method)
get_managed_group_descriptions() (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)
GroupHashingPartitioner (class in pykafka.partitioners)
GroupLoadInProgress
GroupMembershipProtocol (class in pykafka.membershipprotocol)
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)
HeartbeatRequest (class in pykafka.protocol)
HeartbeatResponse (class in pykafka.protocol)
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
InvalidTopic
isr (pykafka.partition.Partition attribute)
J
join() (pykafka.handlers.ThreadingHandler.Queue method)
join_group() (pykafka.broker.Broker method)
JoinGroupRequest (class in pykafka.protocol)
JoinGroupResponse (class in pykafka.protocol)
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
LeaderNotFoundError
leave_group() (pykafka.broker.Broker method)
LeaveGroupRequest (class in pykafka.protocol)
LeaveGroupResponse (class in pykafka.protocol)
ListGroupsRequest (class in pykafka.protocol)
ListGroupsResponse (class in pykafka.protocol)
ListOffsetRequest (class in pykafka.protocol)
ListOffsetRequestV1 (class in pykafka.protocol)
ListOffsetResponse (class in pykafka.protocol)
ListOffsetResponseV1 (class in pykafka.protocol)
Lock() (pykafka.handlers.ThreadingHandler method)
M
ManagedBalancedConsumer (class in pykafka.managedbalancedconsumer)
max_offset (pykafka.protocol.FetchPartitionResponse attribute)
MemberAssignment (class in pykafka.protocol)
Message (class in pykafka.common)
(class in pykafka.protocol)
message_count() (pykafka.protocol.ProduceRequest method)
messages (pykafka.protocol.FetchPartitionResponse attribute)
(pykafka.protocol.ProduceRequest attribute)
MessageSet (class in pykafka.protocol)
MessageSetDecodeFailure
MessageSizeTooLarge
metadata (pykafka.membershipprotocol.GroupMembershipProtocol attribute)
(pykafka.protocol.OffsetFetchPartitionResponse attribute)
MetadataRequest (class in pykafka.protocol)
MetadataRequestV1 (class in pykafka.protocol)
MetadataRequestV2 (class in pykafka.protocol)
MetadataRequestV3 (class in pykafka.protocol)
MetadataRequestV4 (class in pykafka.protocol)
MetadataRequestV5 (class in pykafka.protocol)
MetadataResponse (class in pykafka.protocol)
MetadataResponseV1 (class in pykafka.protocol)
MetadataResponseV2 (class in pykafka.protocol)
MetadataResponseV3 (class in pykafka.protocol)
MetadataResponseV4 (class in pykafka.protocol)
MetadataResponseV5 (class in pykafka.protocol)
N
name (pykafka.topic.Topic attribute)
NoBrokersAvailableError
NoMessagesConsumedError
NotCoordinatorForGroup
NotLeaderForPartition
O
offset (pykafka.protocol.OffsetFetchPartitionResponse attribute)
(pykafka.protocol.ProducePartitionResponse attribute)
OffsetCommitPartitionResponse (class in pykafka.protocol)
OffsetCommitRequest (class in pykafka.protocol)
OffsetCommitResponse (class in pykafka.protocol)
OffsetFetchPartitionResponse (class in pykafka.protocol)
OffsetFetchRequest (class in pykafka.protocol)
OffsetFetchRequestV1 (class in pykafka.protocol)
OffsetFetchRequestV2 (class in pykafka.protocol)
OffsetFetchResponse (class in pykafka.protocol)
OffsetFetchResponseV1 (class in pykafka.protocol)
OffsetFetchResponseV2 (class in pykafka.protocol)
OffsetMetadataTooLarge
OffsetOutOfRangeError
OffsetRequestFailedError
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)
ProduceFailureError
ProducePartitionResponse (class in pykafka.protocol)
Producer (class in pykafka.producer)
ProduceRequest (class in pykafka.protocol)
ProduceResponse (class in pykafka.protocol)
ProducerQueueFullError
ProducerStoppedException
protocol_name (pykafka.membershipprotocol.GroupMembershipProtocol attribute)
protocol_type (pykafka.membershipprotocol.GroupMembershipProtocol attribute)
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.managedbalancedconsumer (module)
pykafka.membershipprotocol (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)
RandomPartitioner (class in 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 (pykafka.handlers.RequestHandler.Task attribute)
request() (pykafka.connection.BrokerConnection method)
(pykafka.handlers.RequestHandler 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() (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)
SockErr (pykafka.handlers.ThreadingHandler attribute)
Socket (pykafka.handlers.ThreadingHandler attribute)
SocketDisconnectedError
spawn() (pykafka.handlers.Handler method)
(pykafka.handlers.ThreadingHandler method)
SslConfig (class in pykafka.connection)
start() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.handlers.RequestHandler method)
(pykafka.managedbalancedconsumer.ManagedBalancedConsumer method)
(pykafka.producer.Producer method)
(pykafka.simpleconsumer.SimpleConsumer method)
stop() (pykafka.balancedconsumer.BalancedConsumer method)
(pykafka.handlers.RequestHandler method)
(pykafka.managedbalancedconsumer.ManagedBalancedConsumer method)
(pykafka.producer.Producer method)
(pykafka.simpleconsumer.SimpleConsumer method)
sync_group() (pykafka.broker.Broker method)
SyncGroupRequest (class in pykafka.protocol)
SyncGroupResponse (class in pykafka.protocol)
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)
timestamp_dt (pykafka.protocol.Message attribute)
Topic (class in pykafka.topic)
topic (pykafka.balancedconsumer.BalancedConsumer attribute)
(pykafka.partition.Partition attribute)
(pykafka.simpleconsumer.SimpleConsumer attribute)
TopicAuthorizationFailed
topics (pykafka.cluster.Cluster attribute)
U
UnicodeException
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)
W
wrap_socket() (pykafka.connection.SslConfig method)
Read the Docs
v: latest
Versions
latest
stable
2.4.0
2.3.1
2.3.0
2.0.4
2.0.3
2.0.2
2.0.1
2.0.0
1.1.1
1.1.0
1.0.3
Downloads
pdf
html
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.