kafka-python
1.4.5
Usage Overview
API
Simple Clients [deprecated]
Install
Tests
Compatibility
Support
License
Changelog
kafka-python
Docs
»
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
A
AbstractPartitionAssignor (class in kafka.coordinator.assignors.abstract)
AbstractType (class in kafka.protocol.abstract)
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)
add_group_coordinator() (kafka.cluster.ClusterMetadata method)
,
[1]
add_listener() (kafka.cluster.ClusterMetadata method)
,
[1]
add_topic() (kafka.client.KafkaClient method)
ALL_TOPICS (kafka.protocol.metadata.MetadataRequest_v0 attribute)
(kafka.protocol.metadata.MetadataRequest_v1 attribute)
(kafka.protocol.metadata.MetadataRequest_v2 attribute)
(kafka.protocol.metadata.MetadataRequest_v3 attribute)
(kafka.protocol.metadata.MetadataRequest_v4 attribute)
(kafka.protocol.metadata.MetadataRequest_v5 attribute)
alter_configs() (kafka.admin.KafkaAdminClient method)
(kafka.KafkaAdminClient method)
AlterConfigsRequest_v0 (class in kafka.protocol.admin)
AlterConfigsResponse_v0 (class in kafka.protocol.admin)
API_KEY (kafka.protocol.admin.AlterConfigsRequest_v0 attribute)
(kafka.protocol.admin.AlterConfigsResponse_v0 attribute)
(kafka.protocol.admin.ApiVersionRequest_v0 attribute)
(kafka.protocol.admin.ApiVersionRequest_v1 attribute)
(kafka.protocol.admin.ApiVersionResponse_v0 attribute)
(kafka.protocol.admin.ApiVersionResponse_v1 attribute)
(kafka.protocol.admin.CreateAclsRequest_v0 attribute)
(kafka.protocol.admin.CreateAclsRequest_v1 attribute)
(kafka.protocol.admin.CreateAclsResponse_v0 attribute)
(kafka.protocol.admin.CreateAclsResponse_v1 attribute)
(kafka.protocol.admin.CreatePartitionsRequest_v0 attribute)
(kafka.protocol.admin.CreatePartitionsResponse_v0 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v0 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v1 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v2 attribute)
(kafka.protocol.admin.CreateTopicsResponse_v0 attribute)
(kafka.protocol.admin.CreateTopicsResponse_v1 attribute)
(kafka.protocol.admin.CreateTopicsResponse_v2 attribute)
(kafka.protocol.admin.DeleteAclsRequest_v0 attribute)
(kafka.protocol.admin.DeleteAclsRequest_v1 attribute)
(kafka.protocol.admin.DeleteAclsResponse_v0 attribute)
(kafka.protocol.admin.DeleteAclsResponse_v1 attribute)
(kafka.protocol.admin.DeleteTopicsRequest_v0 attribute)
(kafka.protocol.admin.DeleteTopicsRequest_v1 attribute)
(kafka.protocol.admin.DeleteTopicsResponse_v0 attribute)
(kafka.protocol.admin.DeleteTopicsResponse_v1 attribute)
(kafka.protocol.admin.DescribeAclsRequest_v0 attribute)
(kafka.protocol.admin.DescribeAclsRequest_v1 attribute)
(kafka.protocol.admin.DescribeAclsResponse_v0 attribute)
(kafka.protocol.admin.DescribeAclsResponse_v1 attribute)
(kafka.protocol.admin.DescribeConfigsRequest_v0 attribute)
(kafka.protocol.admin.DescribeConfigsRequest_v1 attribute)
(kafka.protocol.admin.DescribeConfigsResponse_v0 attribute)
(kafka.protocol.admin.DescribeConfigsResponse_v1 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v0 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v1 attribute)
(kafka.protocol.admin.DescribeGroupsResponse_v0 attribute)
(kafka.protocol.admin.DescribeGroupsResponse_v1 attribute)
(kafka.protocol.admin.ListGroupsRequest_v0 attribute)
(kafka.protocol.admin.ListGroupsRequest_v1 attribute)
(kafka.protocol.admin.ListGroupsResponse_v0 attribute)
(kafka.protocol.admin.ListGroupsResponse_v1 attribute)
(kafka.protocol.admin.SaslAuthenticateRequest_v0 attribute)
(kafka.protocol.admin.SaslAuthenticateResponse_v0 attribute)
(kafka.protocol.admin.SaslHandShakeRequest_v0 attribute)
(kafka.protocol.admin.SaslHandShakeRequest_v1 attribute)
(kafka.protocol.admin.SaslHandShakeResponse_v0 attribute)
(kafka.protocol.admin.SaslHandShakeResponse_v1 attribute)
(kafka.protocol.api.Request attribute)
(kafka.protocol.api.Response attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v1 attribute)
(kafka.protocol.commit.GroupCoordinatorResponse_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorResponse_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v3 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v0 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v1 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v2 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v3 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v0 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v1 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v2 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v3 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v0 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v1 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v2 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v3 attribute)
(kafka.protocol.fetch.FetchRequest_v0 attribute)
(kafka.protocol.fetch.FetchRequest_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v2 attribute)
(kafka.protocol.fetch.FetchRequest_v3 attribute)
(kafka.protocol.fetch.FetchRequest_v4 attribute)
(kafka.protocol.fetch.FetchRequest_v5 attribute)
(kafka.protocol.fetch.FetchRequest_v6 attribute)
(kafka.protocol.fetch.FetchResponse_v0 attribute)
(kafka.protocol.fetch.FetchResponse_v1 attribute)
(kafka.protocol.fetch.FetchResponse_v2 attribute)
(kafka.protocol.fetch.FetchResponse_v3 attribute)
(kafka.protocol.fetch.FetchResponse_v4 attribute)
(kafka.protocol.fetch.FetchResponse_v5 attribute)
(kafka.protocol.fetch.FetchResponse_v6 attribute)
(kafka.protocol.group.HeartbeatRequest_v0 attribute)
(kafka.protocol.group.HeartbeatRequest_v1 attribute)
(kafka.protocol.group.HeartbeatResponse_v0 attribute)
(kafka.protocol.group.HeartbeatResponse_v1 attribute)
(kafka.protocol.group.JoinGroupRequest_v0 attribute)
(kafka.protocol.group.JoinGroupRequest_v1 attribute)
(kafka.protocol.group.JoinGroupRequest_v2 attribute)
(kafka.protocol.group.JoinGroupResponse_v0 attribute)
(kafka.protocol.group.JoinGroupResponse_v1 attribute)
(kafka.protocol.group.JoinGroupResponse_v2 attribute)
(kafka.protocol.group.LeaveGroupRequest_v0 attribute)
(kafka.protocol.group.LeaveGroupRequest_v1 attribute)
(kafka.protocol.group.LeaveGroupResponse_v0 attribute)
(kafka.protocol.group.LeaveGroupResponse_v1 attribute)
(kafka.protocol.group.SyncGroupRequest_v0 attribute)
(kafka.protocol.group.SyncGroupRequest_v1 attribute)
(kafka.protocol.group.SyncGroupResponse_v0 attribute)
(kafka.protocol.group.SyncGroupResponse_v1 attribute)
(kafka.protocol.metadata.MetadataRequest_v0 attribute)
(kafka.protocol.metadata.MetadataRequest_v1 attribute)
(kafka.protocol.metadata.MetadataRequest_v2 attribute)
(kafka.protocol.metadata.MetadataRequest_v3 attribute)
(kafka.protocol.metadata.MetadataRequest_v4 attribute)
(kafka.protocol.metadata.MetadataRequest_v5 attribute)
(kafka.protocol.metadata.MetadataResponse_v0 attribute)
(kafka.protocol.metadata.MetadataResponse_v1 attribute)
(kafka.protocol.metadata.MetadataResponse_v2 attribute)
(kafka.protocol.metadata.MetadataResponse_v3 attribute)
(kafka.protocol.metadata.MetadataResponse_v4 attribute)
(kafka.protocol.metadata.MetadataResponse_v5 attribute)
(kafka.protocol.offset.OffsetRequest_v0 attribute)
(kafka.protocol.offset.OffsetRequest_v1 attribute)
(kafka.protocol.offset.OffsetRequest_v2 attribute)
(kafka.protocol.offset.OffsetResponse_v0 attribute)
(kafka.protocol.offset.OffsetResponse_v1 attribute)
(kafka.protocol.offset.OffsetResponse_v2 attribute)
(kafka.protocol.produce.ProduceResponse_v0 attribute)
(kafka.protocol.produce.ProduceResponse_v1 attribute)
(kafka.protocol.produce.ProduceResponse_v2 attribute)
(kafka.protocol.produce.ProduceResponse_v3 attribute)
(kafka.protocol.produce.ProduceResponse_v4 attribute)
(kafka.protocol.produce.ProduceResponse_v5 attribute)
API_VERSION (kafka.protocol.admin.AlterConfigsRequest_v0 attribute)
(kafka.protocol.admin.AlterConfigsResponse_v0 attribute)
(kafka.protocol.admin.ApiVersionRequest_v0 attribute)
(kafka.protocol.admin.ApiVersionRequest_v1 attribute)
(kafka.protocol.admin.ApiVersionResponse_v0 attribute)
(kafka.protocol.admin.ApiVersionResponse_v1 attribute)
(kafka.protocol.admin.CreateAclsRequest_v0 attribute)
(kafka.protocol.admin.CreateAclsRequest_v1 attribute)
(kafka.protocol.admin.CreateAclsResponse_v0 attribute)
(kafka.protocol.admin.CreateAclsResponse_v1 attribute)
(kafka.protocol.admin.CreatePartitionsRequest_v0 attribute)
(kafka.protocol.admin.CreatePartitionsResponse_v0 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v0 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v1 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v2 attribute)
(kafka.protocol.admin.CreateTopicsResponse_v0 attribute)
(kafka.protocol.admin.CreateTopicsResponse_v1 attribute)
(kafka.protocol.admin.CreateTopicsResponse_v2 attribute)
(kafka.protocol.admin.DeleteAclsRequest_v0 attribute)
(kafka.protocol.admin.DeleteAclsRequest_v1 attribute)
(kafka.protocol.admin.DeleteAclsResponse_v0 attribute)
(kafka.protocol.admin.DeleteAclsResponse_v1 attribute)
(kafka.protocol.admin.DeleteTopicsRequest_v0 attribute)
(kafka.protocol.admin.DeleteTopicsRequest_v1 attribute)
(kafka.protocol.admin.DeleteTopicsResponse_v0 attribute)
(kafka.protocol.admin.DeleteTopicsResponse_v1 attribute)
(kafka.protocol.admin.DescribeAclsRequest_v0 attribute)
(kafka.protocol.admin.DescribeAclsRequest_v1 attribute)
(kafka.protocol.admin.DescribeAclsResponse_v0 attribute)
(kafka.protocol.admin.DescribeAclsResponse_v1 attribute)
(kafka.protocol.admin.DescribeConfigsRequest_v0 attribute)
(kafka.protocol.admin.DescribeConfigsRequest_v1 attribute)
(kafka.protocol.admin.DescribeConfigsResponse_v0 attribute)
(kafka.protocol.admin.DescribeConfigsResponse_v1 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v0 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v1 attribute)
(kafka.protocol.admin.DescribeGroupsResponse_v0 attribute)
(kafka.protocol.admin.DescribeGroupsResponse_v1 attribute)
(kafka.protocol.admin.ListGroupsRequest_v0 attribute)
(kafka.protocol.admin.ListGroupsRequest_v1 attribute)
(kafka.protocol.admin.ListGroupsResponse_v0 attribute)
(kafka.protocol.admin.ListGroupsResponse_v1 attribute)
(kafka.protocol.admin.SaslAuthenticateRequest_v0 attribute)
(kafka.protocol.admin.SaslAuthenticateResponse_v0 attribute)
(kafka.protocol.admin.SaslHandShakeRequest_v0 attribute)
(kafka.protocol.admin.SaslHandShakeRequest_v1 attribute)
(kafka.protocol.admin.SaslHandShakeResponse_v0 attribute)
(kafka.protocol.admin.SaslHandShakeResponse_v1 attribute)
(kafka.protocol.api.Request attribute)
(kafka.protocol.api.Response attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v1 attribute)
(kafka.protocol.commit.GroupCoordinatorResponse_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorResponse_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v3 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v0 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v1 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v2 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v3 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v0 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v1 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v2 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v3 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v0 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v1 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v2 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v3 attribute)
(kafka.protocol.fetch.FetchRequest_v0 attribute)
(kafka.protocol.fetch.FetchRequest_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v2 attribute)
(kafka.protocol.fetch.FetchRequest_v3 attribute)
(kafka.protocol.fetch.FetchRequest_v4 attribute)
(kafka.protocol.fetch.FetchRequest_v5 attribute)
(kafka.protocol.fetch.FetchRequest_v6 attribute)
(kafka.protocol.fetch.FetchResponse_v0 attribute)
(kafka.protocol.fetch.FetchResponse_v1 attribute)
(kafka.protocol.fetch.FetchResponse_v2 attribute)
(kafka.protocol.fetch.FetchResponse_v3 attribute)
(kafka.protocol.fetch.FetchResponse_v4 attribute)
(kafka.protocol.fetch.FetchResponse_v5 attribute)
(kafka.protocol.fetch.FetchResponse_v6 attribute)
(kafka.protocol.group.HeartbeatRequest_v0 attribute)
(kafka.protocol.group.HeartbeatRequest_v1 attribute)
(kafka.protocol.group.HeartbeatResponse_v0 attribute)
(kafka.protocol.group.HeartbeatResponse_v1 attribute)
(kafka.protocol.group.JoinGroupRequest_v0 attribute)
(kafka.protocol.group.JoinGroupRequest_v1 attribute)
(kafka.protocol.group.JoinGroupRequest_v2 attribute)
(kafka.protocol.group.JoinGroupResponse_v0 attribute)
(kafka.protocol.group.JoinGroupResponse_v1 attribute)
(kafka.protocol.group.JoinGroupResponse_v2 attribute)
(kafka.protocol.group.LeaveGroupRequest_v0 attribute)
(kafka.protocol.group.LeaveGroupRequest_v1 attribute)
(kafka.protocol.group.LeaveGroupResponse_v0 attribute)
(kafka.protocol.group.LeaveGroupResponse_v1 attribute)
(kafka.protocol.group.SyncGroupRequest_v0 attribute)
(kafka.protocol.group.SyncGroupRequest_v1 attribute)
(kafka.protocol.group.SyncGroupResponse_v0 attribute)
(kafka.protocol.group.SyncGroupResponse_v1 attribute)
(kafka.protocol.metadata.MetadataRequest_v0 attribute)
(kafka.protocol.metadata.MetadataRequest_v1 attribute)
(kafka.protocol.metadata.MetadataRequest_v2 attribute)
(kafka.protocol.metadata.MetadataRequest_v3 attribute)
(kafka.protocol.metadata.MetadataRequest_v4 attribute)
(kafka.protocol.metadata.MetadataRequest_v5 attribute)
(kafka.protocol.metadata.MetadataResponse_v0 attribute)
(kafka.protocol.metadata.MetadataResponse_v1 attribute)
(kafka.protocol.metadata.MetadataResponse_v2 attribute)
(kafka.protocol.metadata.MetadataResponse_v3 attribute)
(kafka.protocol.metadata.MetadataResponse_v4 attribute)
(kafka.protocol.metadata.MetadataResponse_v5 attribute)
(kafka.protocol.offset.OffsetRequest_v0 attribute)
(kafka.protocol.offset.OffsetRequest_v1 attribute)
(kafka.protocol.offset.OffsetRequest_v2 attribute)
(kafka.protocol.offset.OffsetResponse_v0 attribute)
(kafka.protocol.offset.OffsetResponse_v1 attribute)
(kafka.protocol.offset.OffsetResponse_v2 attribute)
(kafka.protocol.produce.ProduceRequest_v0 attribute)
(kafka.protocol.produce.ProduceRequest_v1 attribute)
(kafka.protocol.produce.ProduceRequest_v2 attribute)
(kafka.protocol.produce.ProduceRequest_v3 attribute)
(kafka.protocol.produce.ProduceRequest_v4 attribute)
(kafka.protocol.produce.ProduceRequest_v5 attribute)
(kafka.protocol.produce.ProduceResponse_v0 attribute)
(kafka.protocol.produce.ProduceResponse_v1 attribute)
(kafka.protocol.produce.ProduceResponse_v2 attribute)
(kafka.protocol.produce.ProduceResponse_v3 attribute)
(kafka.protocol.produce.ProduceResponse_v4 attribute)
(kafka.protocol.produce.ProduceResponse_v5 attribute)
ApiVersionRequest_v0 (class in kafka.protocol.admin)
ApiVersionRequest_v1 (class in kafka.protocol.admin)
ApiVersionResponse_v0 (class in kafka.protocol.admin)
ApiVersionResponse_v1 (class in kafka.protocol.admin)
Array (class in kafka.protocol.types)
assign() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
(kafka.coordinator.assignors.abstract.AbstractPartitionAssignor method)
(kafka.coordinator.assignors.roundrobin.RoundRobinPartitionAssignor class method)
assignment() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
AUTHENTICATING (kafka.conn.ConnectionStates attribute)
available_partitions_for_topic() (kafka.cluster.ClusterMetadata method)
,
[1]
B
BaseCoordinator (class in kafka.coordinator.base)
beginning_offsets() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
blacked_out() (kafka.BrokerConnection method)
,
[1]
(kafka.conn.BrokerConnection method)
Boolean (class in kafka.protocol.types)
broker_metadata() (kafka.cluster.ClusterMetadata method)
,
[1]
BrokerConnection (class in kafka)
,
[1]
(class in kafka.conn)
BrokerConnectionMetrics (class in kafka.conn)
brokers() (kafka.cluster.ClusterMetadata method)
,
[1]
Bytes (class in kafka.protocol.types)
C
CachedPartitionCycler (class in kafka.partitioner.roundrobin)
can_send_more() (kafka.BrokerConnection method)
,
[1]
(kafka.conn.BrokerConnection method)
check_version() (kafka.BrokerConnection method)
,
[1]
(kafka.client.KafkaClient method)
(kafka.conn.BrokerConnection method)
CLIENT_ID (kafka.client.SimpleClient attribute)
(kafka.SimpleClient attribute)
close() (kafka.admin.KafkaAdminClient method)
(kafka.BrokerConnection method)
,
[1]
(kafka.KafkaAdminClient method)
(kafka.KafkaConsumer method)
,
[1]
(kafka.KafkaProducer method)
,
[1]
(kafka.SimpleClient method)
(kafka.client.KafkaClient method)
(kafka.client.SimpleClient method)
(kafka.conn.BrokerConnection method)
(kafka.consumer.KafkaConsumer method)
(kafka.coordinator.base.BaseCoordinator method)
(kafka.coordinator.base.HeartbeatThread method)
(kafka.coordinator.consumer.ConsumerCoordinator method)
(kafka.producer.KafkaProducer method)
cluster (kafka.client.KafkaClient attribute)
ClusterMetadata (class in kafka.cluster)
,
[1]
CODEC_GZIP (kafka.protocol.message.Message attribute)
CODEC_LZ4 (kafka.protocol.message.Message attribute)
CODEC_MASK (kafka.protocol.message.Message attribute)
CODEC_SNAPPY (kafka.protocol.message.Message attribute)
collect_hosts() (in module kafka.conn)
commit() (kafka.consumer.base.Consumer method)
(kafka.KafkaConsumer method)
,
[1]
(kafka.consumer.KafkaConsumer method)
(kafka.context.OffsetCommitContext method)
commit_async() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
commit_offsets_async() (kafka.coordinator.consumer.ConsumerCoordinator method)
commit_offsets_sync() (kafka.coordinator.consumer.ConsumerCoordinator method)
commit_partition_offsets() (kafka.context.OffsetCommitContext method)
committed() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
configure() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
connect() (kafka.BrokerConnection method)
,
[1]
(kafka.conn.BrokerConnection method)
connect_blocking() (kafka.BrokerConnection method)
(kafka.conn.BrokerConnection method)
CONNECTED (kafka.conn.ConnectionStates attribute)
connected() (kafka.BrokerConnection method)
,
[1]
(kafka.client.KafkaClient method)
(kafka.conn.BrokerConnection method)
CONNECTING (kafka.conn.ConnectionStates attribute)
connecting() (kafka.BrokerConnection method)
,
[1]
(kafka.conn.BrokerConnection method)
connection_delay() (kafka.BrokerConnection method)
,
[1]
(kafka.client.KafkaClient method)
(kafka.conn.BrokerConnection method)
ConnectionStates (class in kafka.conn)
Consumer (class in kafka.consumer.base)
CONSUMER_METADATA_KEY (kafka.protocol.legacy.KafkaProtocol attribute)
ConsumerCoordinator (class in kafka.coordinator.consumer)
ConsumerCoordinatorMetrics (class in kafka.coordinator.consumer)
ConsumerRebalanceListener (class in kafka)
coordinator() (kafka.coordinator.base.BaseCoordinator method)
coordinator_dead() (kafka.coordinator.base.BaseCoordinator method)
coordinator_for_group() (kafka.cluster.ClusterMetadata method)
,
[1]
coordinator_unknown() (kafka.coordinator.base.BaseCoordinator method)
copy() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
create_gzip_message() (in module kafka)
(in module kafka.protocol.legacy)
create_message() (in module kafka)
(in module kafka.protocol.legacy)
create_message_set() (in module kafka.protocol.legacy)
create_partitions() (kafka.admin.KafkaAdminClient method)
(kafka.KafkaAdminClient method)
create_snappy_message() (in module kafka)
(in module kafka.protocol.legacy)
create_topics() (kafka.admin.KafkaAdminClient method)
(kafka.KafkaAdminClient method)
CreateAclsRequest_v0 (class in kafka.protocol.admin)
CreateAclsRequest_v1 (class in kafka.protocol.admin)
CreateAclsResponse_v0 (class in kafka.protocol.admin)
CreateAclsResponse_v1 (class in kafka.protocol.admin)
CreatePartitionsRequest_v0 (class in kafka.protocol.admin)
CreatePartitionsResponse_v0 (class in kafka.protocol.admin)
CreateTopicsRequest_v0 (class in kafka.protocol.admin)
CreateTopicsRequest_v1 (class in kafka.protocol.admin)
CreateTopicsRequest_v2 (class in kafka.protocol.admin)
CreateTopicsResponse_v0 (class in kafka.protocol.admin)
CreateTopicsResponse_v1 (class in kafka.protocol.admin)
CreateTopicsResponse_v2 (class in kafka.protocol.admin)
D
decode() (kafka.protocol.abstract.AbstractType method)
(kafka.protocol.message.Message class method)
(kafka.protocol.message.MessageSet class method)
(kafka.protocol.struct.Struct class method)
(kafka.protocol.types.Array method)
(kafka.protocol.types.Boolean class method)
(kafka.protocol.types.Bytes class method)
(kafka.protocol.types.Int16 class method)
(kafka.protocol.types.Int32 class method)
(kafka.protocol.types.Int64 class method)
(kafka.protocol.types.Int8 class method)
(kafka.protocol.types.Schema method)
(kafka.protocol.types.String method)
decode_consumer_metadata_response() (kafka.protocol.legacy.KafkaProtocol class method)
decode_fetch_response() (kafka.protocol.legacy.KafkaProtocol class method)
decode_list_offset_response() (kafka.protocol.legacy.KafkaProtocol class method)
decode_message_set() (kafka.protocol.legacy.KafkaProtocol class method)
decode_metadata_response() (kafka.protocol.legacy.KafkaProtocol class method)
decode_offset_commit_response() (kafka.protocol.legacy.KafkaProtocol class method)
decode_offset_fetch_response() (kafka.protocol.legacy.KafkaProtocol class method)
decode_offset_response() (kafka.protocol.legacy.KafkaProtocol class method)
decode_produce_response() (kafka.protocol.legacy.KafkaProtocol class method)
decompress() (kafka.protocol.message.Message method)
DEFAULT_ACK_TIMEOUT (kafka.producer.base.Producer attribute)
DEFAULT_CONFIG (kafka.BrokerConnection attribute)
(kafka.KafkaAdminClient attribute)
(kafka.KafkaConsumer attribute)
(kafka.KafkaProducer attribute)
(kafka.cluster.ClusterMetadata attribute)
(kafka.conn.BrokerConnection attribute)
(kafka.consumer.KafkaConsumer attribute)
(kafka.coordinator.base.BaseCoordinator attribute)
(kafka.coordinator.consumer.ConsumerCoordinator attribute)
(kafka.coordinator.heartbeat.Heartbeat attribute)
(kafka.producer.KafkaProducer attribute)
DEFAULT_GENERATION_ID (kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
DEFAULT_RETENTION_TIME (kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
DEFAULT_SESSION_TIMEOUT_MS_0_9 (kafka.consumer.KafkaConsumer attribute)
(kafka.KafkaConsumer attribute)
DEFAULT_SOCKET_TIMEOUT_SECONDS (kafka.client.SimpleClient attribute)
(kafka.SimpleClient attribute)
DefaultPartitioner (class in kafka.partitioner)
DEFAULTS (kafka.protocol.offset.OffsetRequest_v0 attribute)
(kafka.protocol.offset.OffsetRequest_v1 attribute)
(kafka.protocol.offset.OffsetRequest_v2 attribute)
delete_topics() (kafka.admin.KafkaAdminClient method)
(kafka.KafkaAdminClient method)
DeleteAclsRequest_v0 (class in kafka.protocol.admin)
DeleteAclsRequest_v1 (class in kafka.protocol.admin)
DeleteAclsResponse_v0 (class in kafka.protocol.admin)
DeleteAclsResponse_v1 (class in kafka.protocol.admin)
DeleteTopicsRequest_v0 (class in kafka.protocol.admin)
DeleteTopicsRequest_v1 (class in kafka.protocol.admin)
DeleteTopicsResponse_v0 (class in kafka.protocol.admin)
DeleteTopicsResponse_v1 (class in kafka.protocol.admin)
describe_configs() (kafka.admin.KafkaAdminClient method)
(kafka.KafkaAdminClient method)
describe_consumer_groups() (kafka.admin.KafkaAdminClient method)
(kafka.KafkaAdminClient method)
DescribeAclsRequest_v0 (class in kafka.protocol.admin)
DescribeAclsRequest_v1 (class in kafka.protocol.admin)
DescribeAclsResponse_v0 (class in kafka.protocol.admin)
DescribeAclsResponse_v1 (class in kafka.protocol.admin)
DescribeConfigsRequest_v0 (class in kafka.protocol.admin)
DescribeConfigsRequest_v1 (class in kafka.protocol.admin)
DescribeConfigsResponse_v0 (class in kafka.protocol.admin)
DescribeConfigsResponse_v1 (class in kafka.protocol.admin)
DescribeGroupsRequest_v0 (class in kafka.protocol.admin)
DescribeGroupsRequest_v1 (class in kafka.protocol.admin)
DescribeGroupsResponse_v0 (class in kafka.protocol.admin)
DescribeGroupsResponse_v1 (class in kafka.protocol.admin)
Dict (class in kafka.util)
disable() (kafka.coordinator.base.HeartbeatThread method)
DISCONNECTED (kafka.conn.ConnectionStates attribute)
disconnected() (kafka.BrokerConnection method)
,
[1]
(kafka.conn.BrokerConnection method)
DISCONNECTING (kafka.conn.ConnectionStates attribute)
dns_lookup() (in module kafka.conn)
E
EARLIEST (kafka.protocol.offset.OffsetResetStrategy attribute)
enable() (kafka.coordinator.base.HeartbeatThread method)
encode() (kafka.protocol.abstract.AbstractType method)
(kafka.protocol.message.MessageSet class method)
(kafka.protocol.struct.Struct class method)
(kafka.protocol.types.Array method)
(kafka.protocol.types.Boolean class method)
(kafka.protocol.types.Bytes class method)
(kafka.protocol.types.Int16 class method)
(kafka.protocol.types.Int32 class method)
(kafka.protocol.types.Int64 class method)
(kafka.protocol.types.Int8 class method)
(kafka.protocol.types.Schema method)
(kafka.protocol.types.String method)
encode_consumer_metadata_request() (kafka.protocol.legacy.KafkaProtocol class method)
encode_fetch_request() (kafka.protocol.legacy.KafkaProtocol class method)
encode_list_offset_request() (kafka.protocol.legacy.KafkaProtocol class method)
encode_metadata_request() (kafka.protocol.legacy.KafkaProtocol class method)
encode_offset_commit_request() (kafka.protocol.legacy.KafkaProtocol class method)
encode_offset_fetch_request() (kafka.protocol.legacy.KafkaProtocol class method)
encode_offset_request() (kafka.protocol.legacy.KafkaProtocol class method)
encode_produce_request() (kafka.protocol.legacy.KafkaProtocol class method)
end_offsets() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
ensure_active_group() (kafka.coordinator.base.BaseCoordinator method)
ensure_coordinator_ready() (kafka.coordinator.base.BaseCoordinator method)
ensure_topic_exists() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
Events (class in kafka.consumer.multiprocess)
exit (kafka.consumer.multiprocess.Events attribute)
expect_response() (kafka.protocol.api.Request method)
F
fail_heartbeat() (kafka.coordinator.heartbeat.Heartbeat method)
failed_update() (kafka.cluster.ClusterMetadata method)
,
[1]
fetch_committed_offsets() (kafka.coordinator.consumer.ConsumerCoordinator method)
FETCH_KEY (kafka.protocol.legacy.KafkaProtocol attribute)
fetch_last_known_offsets() (kafka.consumer.base.Consumer method)
fetch_messages() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
FetchContext (class in kafka.consumer.simple)
FetchRequest_v0 (class in kafka.protocol.fetch)
FetchRequest_v1 (class in kafka.protocol.fetch)
FetchRequest_v2 (class in kafka.protocol.fetch)
FetchRequest_v3 (class in kafka.protocol.fetch)
FetchRequest_v4 (class in kafka.protocol.fetch)
FetchRequest_v5 (class in kafka.protocol.fetch)
FetchRequest_v6 (class in kafka.protocol.fetch)
FetchResponse_v0 (class in kafka.protocol.fetch)
FetchResponse_v1 (class in kafka.protocol.fetch)
FetchResponse_v2 (class in kafka.protocol.fetch)
FetchResponse_v3 (class in kafka.protocol.fetch)
FetchResponse_v4 (class in kafka.protocol.fetch)
FetchResponse_v5 (class in kafka.protocol.fetch)
FetchResponse_v6 (class in kafka.protocol.fetch)
flush() (kafka.KafkaProducer method)
,
[1]
(kafka.producer.KafkaProducer method)
G
Generation (class in kafka.coordinator.base)
generation() (kafka.coordinator.base.BaseCoordinator method)
get_api_versions() (kafka.BrokerConnection method)
(kafka.client.KafkaClient method)
(kafka.conn.BrokerConnection method)
get_ip_port_afi() (in module kafka.conn)
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.SimpleClient method)
(kafka.SimpleClient method)
get_partition_offsets() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
group_by_topic_and_partition() (in module kafka.util)
group_protocols() (kafka.coordinator.base.BaseCoordinator method)
(kafka.coordinator.consumer.ConsumerCoordinator method)
GroupCoordinatorMetrics (class in kafka.coordinator.base)
GroupCoordinatorRequest_v0 (class in kafka.protocol.commit)
GroupCoordinatorRequest_v1 (class in kafka.protocol.commit)
GroupCoordinatorResponse_v0 (class in kafka.protocol.commit)
GroupCoordinatorResponse_v1 (class in kafka.protocol.commit)
gzip_decode() (in module kafka.codec)
gzip_encode() (in module kafka.codec)
H
handle_out_of_range() (kafka.context.OffsetCommitContext method)
HANDSHAKE (kafka.conn.ConnectionStates attribute)
has_gzip() (in module kafka.codec)
has_lz4() (in module kafka.codec)
has_metadata_for_topic() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
has_snappy() (in module kafka.codec)
HashedPartitioner (in module kafka)
(in module kafka.partitioner)
(in module kafka.partitioner.hashed)
HEADER_SIZE (kafka.protocol.message.Message attribute)
(kafka.protocol.message.MessageSet attribute)
Heartbeat (class in kafka.coordinator.heartbeat)
HeartbeatRequest_v0 (class in kafka.protocol.group)
HeartbeatRequest_v1 (class in kafka.protocol.group)
HeartbeatResponse_v0 (class in kafka.protocol.group)
HeartbeatResponse_v1 (class in kafka.protocol.group)
HeartbeatThread (class in kafka.coordinator.base)
highwater() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
I
in_flight_request_count() (kafka.client.KafkaClient method)
Int16 (class in kafka.protocol.types)
Int32 (class in kafka.protocol.types)
Int64 (class in kafka.protocol.types)
Int8 (class in kafka.protocol.types)
is_compressed() (kafka.protocol.message.Message method)
is_disconnected() (kafka.client.KafkaClient method)
is_inet_4_or_6() (in module kafka.conn)
is_ready() (kafka.client.KafkaClient method)
ITEM (kafka.protocol.message.MessageSet attribute)
J
JoinGroupRequest_v0 (class in kafka.protocol.group)
JoinGroupRequest_v1 (class in kafka.protocol.group)
JoinGroupRequest_v2 (class in kafka.protocol.group)
JoinGroupResponse_v0 (class in kafka.protocol.group)
JoinGroupResponse_v1 (class in kafka.protocol.group)
JoinGroupResponse_v2 (class in kafka.protocol.group)
K
kafka (module)
kafka.client (module)
kafka.cluster (module)
kafka.codec (module)
kafka.common (module)
kafka.conn (module)
kafka.consumer (module)
kafka.consumer.base (module)
kafka.consumer.multiprocess (module)
kafka.consumer.simple (module)
kafka.context (module)
kafka.coordinator (module)
kafka.coordinator.assignors (module)
kafka.coordinator.assignors.abstract (module)
kafka.coordinator.assignors.roundrobin (module)
kafka.coordinator.base (module)
kafka.coordinator.consumer (module)
kafka.coordinator.heartbeat (module)
kafka.partitioner (module)
kafka.partitioner.base (module)
kafka.partitioner.hashed (module)
kafka.partitioner.roundrobin (module)
kafka.producer (module)
kafka.producer.base (module)
,
[1]
kafka.producer.keyed (module)
kafka.producer.simple (module)
kafka.protocol (module)
,
[1]
kafka.protocol.abstract (module)
kafka.protocol.admin (module)
kafka.protocol.api (module)
kafka.protocol.commit (module)
kafka.protocol.fetch (module)
kafka.protocol.group (module)
kafka.protocol.legacy (module)
kafka.protocol.message (module)
kafka.protocol.metadata (module)
kafka.protocol.offset (module)
kafka.protocol.pickle (module)
kafka.protocol.produce (module)
kafka.protocol.struct (module)
kafka.protocol.types (module)
kafka.util (module)
KafkaAdminClient (class in kafka)
(class in kafka.admin)
KafkaClient (class in kafka)
(class in kafka.client)
KafkaConsumer (class in kafka)
,
[1]
(class in kafka.consumer)
KafkaProducer (class in kafka)
,
[1]
(class in kafka.producer)
KafkaProtocol (class in kafka.protocol.legacy)
KeyedProducer (class in kafka)
(class in kafka.producer)
,
[1]
(class in kafka.producer.keyed)
L
LATEST (kafka.protocol.offset.OffsetResetStrategy attribute)
leader_for_partition() (kafka.cluster.ClusterMetadata method)
,
[1]
least_loaded_node() (kafka.client.KafkaClient method)
LeaveGroupRequest_v0 (class in kafka.protocol.group)
LeaveGroupRequest_v1 (class in kafka.protocol.group)
LeaveGroupResponse_v0 (class in kafka.protocol.group)
LeaveGroupResponse_v1 (class in kafka.protocol.group)
LegacyPartitioner (class in kafka.partitioner)
(class in kafka.partitioner.hashed)
list_consumer_group_offsets() (kafka.admin.KafkaAdminClient method)
(kafka.KafkaAdminClient method)
list_consumer_groups() (kafka.admin.KafkaAdminClient method)
(kafka.KafkaAdminClient method)
ListGroupsRequest_v0 (class in kafka.protocol.admin)
ListGroupsRequest_v1 (class in kafka.protocol.admin)
ListGroupsResponse_v0 (class in kafka.protocol.admin)
ListGroupsResponse_v1 (class in kafka.protocol.admin)
load_metadata_for_topics() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
lookup_coordinator() (kafka.coordinator.base.BaseCoordinator method)
lz4_decode_old_kafka() (in module kafka.codec)
lz4_encode_old_kafka() (in module kafka.codec)
lz4f_decode() (in module kafka.codec)
M
mark() (kafka.context.OffsetCommitContext method)
maybe_connect() (kafka.client.KafkaClient method)
maybe_leave_group() (kafka.coordinator.base.BaseCoordinator method)
MemberAssignment (class in kafka.protocol.group)
MemberState (class in kafka.coordinator.base)
Message (class in kafka.protocol.message)
MessageSet (class in kafka.protocol.message)
metadata() (kafka.coordinator.assignors.abstract.AbstractPartitionAssignor method)
(kafka.coordinator.assignors.roundrobin.RoundRobinPartitionAssignor class method)
METADATA_KEY (kafka.protocol.legacy.KafkaProtocol attribute)
MetadataRequest_v0 (class in kafka.protocol.metadata)
MetadataRequest_v1 (class in kafka.protocol.metadata)
MetadataRequest_v2 (class in kafka.protocol.metadata)
MetadataRequest_v3 (class in kafka.protocol.metadata)
MetadataRequest_v4 (class in kafka.protocol.metadata)
MetadataRequest_v5 (class in kafka.protocol.metadata)
MetadataResponse_v0 (class in kafka.protocol.metadata)
MetadataResponse_v1 (class in kafka.protocol.metadata)
MetadataResponse_v2 (class in kafka.protocol.metadata)
MetadataResponse_v3 (class in kafka.protocol.metadata)
MetadataResponse_v4 (class in kafka.protocol.metadata)
MetadataResponse_v5 (class in kafka.protocol.metadata)
metrics() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
(kafka.KafkaProducer method)
,
[1]
(kafka.producer.KafkaProducer method)
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
name (kafka.coordinator.assignors.abstract.AbstractPartitionAssignor attribute)
(kafka.coordinator.assignors.roundrobin.RoundRobinPartitionAssignor attribute)
need_rejoin() (kafka.coordinator.base.BaseCoordinator method)
(kafka.coordinator.consumer.ConsumerCoordinator method)
next() (kafka.partitioner.roundrobin.CachedPartitionCycler method)
NO_GENERATION (kafka.coordinator.base.Generation attribute)
NO_TOPICS (kafka.protocol.metadata.MetadataRequest_v1 attribute)
(kafka.protocol.metadata.MetadataRequest_v2 attribute)
(kafka.protocol.metadata.MetadataRequest_v3 attribute)
(kafka.protocol.metadata.MetadataRequest_v4 attribute)
(kafka.protocol.metadata.MetadataRequest_v5 attribute)
NONE (kafka.protocol.offset.OffsetResetStrategy attribute)
O
OFFSET_COMMIT_KEY (kafka.protocol.legacy.KafkaProtocol attribute)
OFFSET_FETCH_KEY (kafka.protocol.legacy.KafkaProtocol attribute)
OFFSET_KEY (kafka.protocol.legacy.KafkaProtocol attribute)
OffsetCommitContext (class in kafka.context)
OffsetCommitRequest_v0 (class in kafka.protocol.commit)
OffsetCommitRequest_v1 (class in kafka.protocol.commit)
OffsetCommitRequest_v2 (class in kafka.protocol.commit)
OffsetCommitRequest_v3 (class in kafka.protocol.commit)
OffsetCommitResponse_v0 (class in kafka.protocol.commit)
OffsetCommitResponse_v1 (class in kafka.protocol.commit)
OffsetCommitResponse_v2 (class in kafka.protocol.commit)
OffsetCommitResponse_v3 (class in kafka.protocol.commit)
OffsetFetchRequest_v0 (class in kafka.protocol.commit)
OffsetFetchRequest_v1 (class in kafka.protocol.commit)
OffsetFetchRequest_v2 (class in kafka.protocol.commit)
OffsetFetchRequest_v3 (class in kafka.protocol.commit)
OffsetFetchResponse_v0 (class in kafka.protocol.commit)
OffsetFetchResponse_v1 (class in kafka.protocol.commit)
OffsetFetchResponse_v2 (class in kafka.protocol.commit)
OffsetFetchResponse_v3 (class in kafka.protocol.commit)
OffsetRequest_v0 (class in kafka.protocol.offset)
OffsetRequest_v1 (class in kafka.protocol.offset)
OffsetRequest_v2 (class in kafka.protocol.offset)
OffsetResetStrategy (class in kafka.protocol.offset)
OffsetResponse_v0 (class in kafka.protocol.offset)
OffsetResponse_v1 (class in kafka.protocol.offset)
OffsetResponse_v2 (class in kafka.protocol.offset)
offsets() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
offsets_for_times() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
on_assignment() (kafka.coordinator.assignors.abstract.AbstractPartitionAssignor method)
(kafka.coordinator.assignors.roundrobin.RoundRobinPartitionAssignor class method)
on_partitions_assigned() (kafka.ConsumerRebalanceListener method)
on_partitions_revoked() (kafka.ConsumerRebalanceListener method)
P
PartialMessage (class in kafka.protocol.message)
partition() (kafka.partitioner.hashed.LegacyPartitioner method)
(kafka.RoundRobinPartitioner method)
(kafka.partitioner.LegacyPartitioner method)
(kafka.partitioner.Murmur2Partitioner method)
(kafka.partitioner.RoundRobinPartitioner method)
(kafka.partitioner.hashed.Murmur2Partitioner method)
(kafka.partitioner.roundrobin.RoundRobinPartitioner method)
Partitioner (class in kafka.partitioner.base)
partitions_for() (kafka.KafkaProducer method)
,
[1]
(kafka.producer.KafkaProducer method)
partitions_for_broker() (kafka.cluster.ClusterMetadata method)
,
[1]
partitions_for_topic() (kafka.cluster.ClusterMetadata method)
,
[1]
(kafka.KafkaConsumer method)
,
[1]
(kafka.consumer.KafkaConsumer method)
pause (kafka.consumer.multiprocess.Events attribute)
pause() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
paused() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
pending() (kafka.consumer.base.Consumer method)
poll() (kafka.client.KafkaClient method)
(kafka.KafkaConsumer method)
,
[1]
(kafka.consumer.KafkaConsumer method)
(kafka.coordinator.consumer.ConsumerCoordinator method)
(kafka.coordinator.heartbeat.Heartbeat method)
poll_heartbeat() (kafka.coordinator.base.BaseCoordinator method)
poll_timeout_expired() (kafka.coordinator.heartbeat.Heartbeat method)
position() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
PRODUCE_KEY (kafka.protocol.legacy.KafkaProtocol attribute)
Producer (class in kafka.producer.base)
,
[1]
ProduceRequest_v0 (class in kafka.protocol.produce)
ProduceRequest_v1 (class in kafka.protocol.produce)
ProduceRequest_v2 (class in kafka.protocol.produce)
ProduceRequest_v3 (class in kafka.protocol.produce)
ProduceRequest_v4 (class in kafka.protocol.produce)
ProduceRequest_v5 (class in kafka.protocol.produce)
ProduceResponse_v0 (class in kafka.protocol.produce)
ProduceResponse_v1 (class in kafka.protocol.produce)
ProduceResponse_v2 (class in kafka.protocol.produce)
ProduceResponse_v3 (class in kafka.protocol.produce)
ProduceResponse_v4 (class in kafka.protocol.produce)
ProduceResponse_v5 (class in kafka.protocol.produce)
protocol_type() (kafka.coordinator.base.BaseCoordinator method)
(kafka.coordinator.consumer.ConsumerCoordinator method)
ProtocolMetadata (class in kafka.protocol.group)
provide_partition_info() (kafka.consumer.base.Consumer method)
R
read_short_string() (in module kafka.util)
ready() (kafka.client.KafkaClient method)
REBALANCING (kafka.coordinator.base.MemberState attribute)
received_heartbeat() (kafka.coordinator.heartbeat.Heartbeat method)
recv() (kafka.BrokerConnection method)
,
[1]
(kafka.conn.BrokerConnection method)
ReentrantTimer (class in kafka.util)
refresh_backoff() (kafka.cluster.ClusterMetadata method)
,
[1]
refresh_committed_offsets_if_needed() (kafka.coordinator.consumer.ConsumerCoordinator method)
reinit() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
relative_unpack() (in module kafka.util)
remove_listener() (kafka.cluster.ClusterMetadata method)
,
[1]
repr() (kafka.protocol.abstract.AbstractType class method)
(kafka.protocol.message.MessageSet class method)
(kafka.protocol.types.Array method)
(kafka.protocol.types.Bytes class method)
(kafka.protocol.types.Schema method)
Request (class in kafka.protocol.api)
request_rejoin() (kafka.coordinator.base.BaseCoordinator method)
request_update() (kafka.cluster.ClusterMetadata method)
,
[1]
RequestHeader (class in kafka.protocol.api)
requests_timed_out() (kafka.BrokerConnection method)
(kafka.conn.BrokerConnection method)
reset_all_metadata() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
reset_generation() (kafka.coordinator.base.BaseCoordinator method)
reset_partition_offset() (kafka.consumer.simple.SimpleConsumer method)
(kafka.SimpleConsumer method)
(kafka.consumer.SimpleConsumer method)
reset_timeouts() (kafka.coordinator.heartbeat.Heartbeat method)
reset_topic_metadata() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
Response (class in kafka.protocol.api)
RESPONSE_TYPE (kafka.protocol.admin.AlterConfigsRequest_v0 attribute)
(kafka.protocol.admin.ApiVersionRequest_v0 attribute)
(kafka.protocol.admin.ApiVersionRequest_v1 attribute)
(kafka.protocol.admin.CreateAclsRequest_v0 attribute)
(kafka.protocol.admin.CreateAclsRequest_v1 attribute)
(kafka.protocol.admin.CreatePartitionsRequest_v0 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v0 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v1 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v2 attribute)
(kafka.protocol.admin.DeleteAclsRequest_v0 attribute)
(kafka.protocol.admin.DeleteAclsRequest_v1 attribute)
(kafka.protocol.admin.DeleteTopicsRequest_v0 attribute)
(kafka.protocol.admin.DeleteTopicsRequest_v1 attribute)
(kafka.protocol.admin.DescribeAclsRequest_v0 attribute)
(kafka.protocol.admin.DescribeAclsRequest_v1 attribute)
(kafka.protocol.admin.DescribeConfigsRequest_v0 attribute)
(kafka.protocol.admin.DescribeConfigsRequest_v1 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v0 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v1 attribute)
(kafka.protocol.admin.ListGroupsRequest_v0 attribute)
(kafka.protocol.admin.ListGroupsRequest_v1 attribute)
(kafka.protocol.admin.SaslAuthenticateRequest_v0 attribute)
(kafka.protocol.admin.SaslHandShakeRequest_v0 attribute)
(kafka.protocol.admin.SaslHandShakeRequest_v1 attribute)
(kafka.protocol.api.Request attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v3 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v0 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v1 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v2 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v3 attribute)
(kafka.protocol.fetch.FetchRequest_v0 attribute)
(kafka.protocol.fetch.FetchRequest_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v2 attribute)
(kafka.protocol.fetch.FetchRequest_v3 attribute)
(kafka.protocol.fetch.FetchRequest_v4 attribute)
(kafka.protocol.fetch.FetchRequest_v5 attribute)
(kafka.protocol.fetch.FetchRequest_v6 attribute)
(kafka.protocol.group.HeartbeatRequest_v0 attribute)
(kafka.protocol.group.HeartbeatRequest_v1 attribute)
(kafka.protocol.group.JoinGroupRequest_v0 attribute)
(kafka.protocol.group.JoinGroupRequest_v1 attribute)
(kafka.protocol.group.JoinGroupRequest_v2 attribute)
(kafka.protocol.group.LeaveGroupRequest_v0 attribute)
(kafka.protocol.group.LeaveGroupRequest_v1 attribute)
(kafka.protocol.group.SyncGroupRequest_v0 attribute)
(kafka.protocol.group.SyncGroupRequest_v1 attribute)
(kafka.protocol.metadata.MetadataRequest_v0 attribute)
(kafka.protocol.metadata.MetadataRequest_v1 attribute)
(kafka.protocol.metadata.MetadataRequest_v2 attribute)
(kafka.protocol.metadata.MetadataRequest_v3 attribute)
(kafka.protocol.metadata.MetadataRequest_v4 attribute)
(kafka.protocol.metadata.MetadataRequest_v5 attribute)
(kafka.protocol.offset.OffsetRequest_v0 attribute)
(kafka.protocol.offset.OffsetRequest_v1 attribute)
(kafka.protocol.offset.OffsetRequest_v2 attribute)
(kafka.protocol.produce.ProduceRequest_v0 attribute)
(kafka.protocol.produce.ProduceRequest_v1 attribute)
(kafka.protocol.produce.ProduceRequest_v2 attribute)
(kafka.protocol.produce.ProduceRequest_v3 attribute)
(kafka.protocol.produce.ProduceRequest_v4 attribute)
(kafka.protocol.produce.ProduceRequest_v5 attribute)
resume() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
retriable (kafka.coordinator.base.UnjoinedGroupException attribute)
rollback() (kafka.context.OffsetCommitContext method)
RoundRobinPartitionAssignor (class in kafka.coordinator.assignors.roundrobin)
RoundRobinPartitioner (class in kafka)
(class in kafka.partitioner)
(class in kafka.partitioner.roundrobin)
run() (kafka.coordinator.base.HeartbeatThread method)
S
SASL_MECHANISMS (kafka.BrokerConnection attribute)
(kafka.conn.BrokerConnection attribute)
SaslAuthenticateRequest_v0 (class in kafka.protocol.admin)
SaslAuthenticateResponse_v0 (class in kafka.protocol.admin)
SaslHandShakeRequest_v0 (class in kafka.protocol.admin)
SaslHandShakeRequest_v1 (class in kafka.protocol.admin)
SaslHandShakeResponse_v0 (class in kafka.protocol.admin)
SaslHandShakeResponse_v1 (class in kafka.protocol.admin)
Schema (class in kafka.protocol.types)
SCHEMA (kafka.protocol.admin.AlterConfigsRequest_v0 attribute)
(kafka.protocol.admin.AlterConfigsResponse_v0 attribute)
(kafka.protocol.admin.ApiVersionRequest_v0 attribute)
(kafka.protocol.admin.ApiVersionRequest_v1 attribute)
(kafka.protocol.admin.ApiVersionResponse_v0 attribute)
(kafka.protocol.admin.ApiVersionResponse_v1 attribute)
(kafka.protocol.admin.CreateAclsRequest_v0 attribute)
(kafka.protocol.admin.CreateAclsRequest_v1 attribute)
(kafka.protocol.admin.CreateAclsResponse_v0 attribute)
(kafka.protocol.admin.CreateAclsResponse_v1 attribute)
(kafka.protocol.admin.CreatePartitionsRequest_v0 attribute)
(kafka.protocol.admin.CreatePartitionsResponse_v0 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v0 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v1 attribute)
(kafka.protocol.admin.CreateTopicsRequest_v2 attribute)
(kafka.protocol.admin.CreateTopicsResponse_v0 attribute)
(kafka.protocol.admin.CreateTopicsResponse_v1 attribute)
(kafka.protocol.admin.CreateTopicsResponse_v2 attribute)
(kafka.protocol.admin.DeleteAclsRequest_v0 attribute)
(kafka.protocol.admin.DeleteAclsRequest_v1 attribute)
(kafka.protocol.admin.DeleteAclsResponse_v0 attribute)
(kafka.protocol.admin.DeleteAclsResponse_v1 attribute)
(kafka.protocol.admin.DeleteTopicsRequest_v0 attribute)
(kafka.protocol.admin.DeleteTopicsRequest_v1 attribute)
(kafka.protocol.admin.DeleteTopicsResponse_v0 attribute)
(kafka.protocol.admin.DeleteTopicsResponse_v1 attribute)
(kafka.protocol.admin.DescribeAclsRequest_v0 attribute)
(kafka.protocol.admin.DescribeAclsRequest_v1 attribute)
(kafka.protocol.admin.DescribeAclsResponse_v0 attribute)
(kafka.protocol.admin.DescribeAclsResponse_v1 attribute)
(kafka.protocol.admin.DescribeConfigsRequest_v0 attribute)
(kafka.protocol.admin.DescribeConfigsRequest_v1 attribute)
(kafka.protocol.admin.DescribeConfigsResponse_v0 attribute)
(kafka.protocol.admin.DescribeConfigsResponse_v1 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v0 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v1 attribute)
(kafka.protocol.admin.DescribeGroupsResponse_v0 attribute)
(kafka.protocol.admin.DescribeGroupsResponse_v1 attribute)
(kafka.protocol.admin.ListGroupsRequest_v0 attribute)
(kafka.protocol.admin.ListGroupsRequest_v1 attribute)
(kafka.protocol.admin.ListGroupsResponse_v0 attribute)
(kafka.protocol.admin.ListGroupsResponse_v1 attribute)
(kafka.protocol.admin.SaslAuthenticateRequest_v0 attribute)
(kafka.protocol.admin.SaslAuthenticateResponse_v0 attribute)
(kafka.protocol.admin.SaslHandShakeRequest_v0 attribute)
(kafka.protocol.admin.SaslHandShakeRequest_v1 attribute)
(kafka.protocol.admin.SaslHandShakeResponse_v0 attribute)
(kafka.protocol.admin.SaslHandShakeResponse_v1 attribute)
(kafka.protocol.api.Request attribute)
(kafka.protocol.api.RequestHeader attribute)
(kafka.protocol.api.Response attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v1 attribute)
(kafka.protocol.commit.GroupCoordinatorResponse_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorResponse_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v3 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v0 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v1 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v2 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v3 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v0 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v1 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v2 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v3 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v0 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v1 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v2 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v3 attribute)
(kafka.protocol.fetch.FetchRequest_v0 attribute)
(kafka.protocol.fetch.FetchRequest_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v2 attribute)
(kafka.protocol.fetch.FetchRequest_v3 attribute)
(kafka.protocol.fetch.FetchRequest_v4 attribute)
(kafka.protocol.fetch.FetchRequest_v5 attribute)
(kafka.protocol.fetch.FetchRequest_v6 attribute)
(kafka.protocol.fetch.FetchResponse_v0 attribute)
(kafka.protocol.fetch.FetchResponse_v1 attribute)
(kafka.protocol.fetch.FetchResponse_v2 attribute)
(kafka.protocol.fetch.FetchResponse_v3 attribute)
(kafka.protocol.fetch.FetchResponse_v4 attribute)
(kafka.protocol.fetch.FetchResponse_v5 attribute)
(kafka.protocol.fetch.FetchResponse_v6 attribute)
(kafka.protocol.group.HeartbeatRequest_v0 attribute)
(kafka.protocol.group.HeartbeatRequest_v1 attribute)
(kafka.protocol.group.HeartbeatResponse_v0 attribute)
(kafka.protocol.group.HeartbeatResponse_v1 attribute)
(kafka.protocol.group.JoinGroupRequest_v0 attribute)
(kafka.protocol.group.JoinGroupRequest_v1 attribute)
(kafka.protocol.group.JoinGroupRequest_v2 attribute)
(kafka.protocol.group.JoinGroupResponse_v0 attribute)
(kafka.protocol.group.JoinGroupResponse_v1 attribute)
(kafka.protocol.group.JoinGroupResponse_v2 attribute)
(kafka.protocol.group.LeaveGroupRequest_v0 attribute)
(kafka.protocol.group.LeaveGroupRequest_v1 attribute)
(kafka.protocol.group.LeaveGroupResponse_v0 attribute)
(kafka.protocol.group.LeaveGroupResponse_v1 attribute)
(kafka.protocol.group.MemberAssignment attribute)
(kafka.protocol.group.ProtocolMetadata attribute)
(kafka.protocol.group.SyncGroupRequest_v0 attribute)
(kafka.protocol.group.SyncGroupRequest_v1 attribute)
(kafka.protocol.group.SyncGroupResponse_v0 attribute)
(kafka.protocol.group.SyncGroupResponse_v1 attribute)
(kafka.protocol.message.Message attribute)
(kafka.protocol.metadata.MetadataRequest_v0 attribute)
(kafka.protocol.metadata.MetadataRequest_v1 attribute)
(kafka.protocol.metadata.MetadataRequest_v2 attribute)
(kafka.protocol.metadata.MetadataRequest_v3 attribute)
(kafka.protocol.metadata.MetadataRequest_v4 attribute)
(kafka.protocol.metadata.MetadataRequest_v5 attribute)
(kafka.protocol.metadata.MetadataResponse_v0 attribute)
(kafka.protocol.metadata.MetadataResponse_v1 attribute)
(kafka.protocol.metadata.MetadataResponse_v2 attribute)
(kafka.protocol.metadata.MetadataResponse_v3 attribute)
(kafka.protocol.metadata.MetadataResponse_v4 attribute)
(kafka.protocol.metadata.MetadataResponse_v5 attribute)
(kafka.protocol.offset.OffsetRequest_v0 attribute)
(kafka.protocol.offset.OffsetRequest_v1 attribute)
(kafka.protocol.offset.OffsetRequest_v2 attribute)
(kafka.protocol.offset.OffsetResponse_v0 attribute)
(kafka.protocol.offset.OffsetResponse_v1 attribute)
(kafka.protocol.offset.OffsetResponse_v2 attribute)
(kafka.protocol.produce.ProduceRequest_v0 attribute)
(kafka.protocol.produce.ProduceRequest_v1 attribute)
(kafka.protocol.produce.ProduceRequest_v2 attribute)
(kafka.protocol.produce.ProduceRequest_v3 attribute)
(kafka.protocol.produce.ProduceRequest_v4 attribute)
(kafka.protocol.produce.ProduceRequest_v5 attribute)
(kafka.protocol.produce.ProduceResponse_v0 attribute)
(kafka.protocol.produce.ProduceResponse_v1 attribute)
(kafka.protocol.produce.ProduceResponse_v2 attribute)
(kafka.protocol.produce.ProduceResponse_v3 attribute)
(kafka.protocol.produce.ProduceResponse_v4 attribute)
(kafka.protocol.produce.ProduceResponse_v5 attribute)
(kafka.protocol.struct.Struct attribute)
SCHEMAS (kafka.protocol.message.Message attribute)
SECURITY_PROTOCOLS (kafka.BrokerConnection attribute)
(kafka.conn.BrokerConnection attribute)
seek() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
(kafka.SimpleConsumer method)
(kafka.consumer.SimpleConsumer method)
(kafka.consumer.simple.SimpleConsumer method)
seek_to_beginning() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
seek_to_end() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
send() (kafka.BrokerConnection method)
,
[1]
(kafka.KafkaProducer method)
,
[1]
(kafka.KeyedProducer method)
(kafka.client.KafkaClient method)
(kafka.conn.BrokerConnection method)
(kafka.producer.KafkaProducer method)
(kafka.producer.KeyedProducer method)
(kafka.producer.keyed.KeyedProducer method)
send_consumer_metadata_request() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
send_fetch_request() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
send_list_offset_request() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
send_messages() (kafka.KeyedProducer method)
(kafka.SimpleProducer method)
(kafka.producer.KeyedProducer method)
,
[1]
(kafka.producer.SimpleProducer method)
,
[1]
(kafka.producer.base.Producer method)
,
[1]
(kafka.producer.keyed.KeyedProducer method)
(kafka.producer.simple.SimpleProducer method)
send_metadata_request() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
send_offset_commit_request() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
send_offset_fetch_request() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
send_offset_fetch_request_kafka() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
send_offset_request() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
send_pending_requests() (kafka.BrokerConnection method)
,
[1]
(kafka.conn.BrokerConnection method)
send_produce_request() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
sent_heartbeat() (kafka.coordinator.heartbeat.Heartbeat method)
session_timeout_expired() (kafka.coordinator.heartbeat.Heartbeat method)
set_partitions() (kafka.partitioner.roundrobin.CachedPartitionCycler method)
set_topic_partitions() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
set_topics() (kafka.client.KafkaClient method)
should_heartbeat() (kafka.coordinator.heartbeat.Heartbeat method)
SimpleClient (class in kafka)
(class in kafka.client)
SimpleConsumer (class in kafka)
(class in kafka.consumer)
(class in kafka.consumer.simple)
SimpleProducer (class in kafka)
(class in kafka.producer)
,
[1]
(class in kafka.producer.simple)
snappy_decode() (in module kafka.codec)
snappy_encode() (in module kafka.codec)
STABLE (kafka.coordinator.base.MemberState attribute)
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)
,
[1]
(kafka.util.ReentrantTimer method)
String (class in kafka.protocol.types)
Struct (class in kafka.protocol.struct)
subscribe() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
subscription() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
SyncGroupRequest_v0 (class in kafka.protocol.group)
SyncGroupRequest_v1 (class in kafka.protocol.group)
SyncGroupResponse_v0 (class in kafka.protocol.group)
SyncGroupResponse_v1 (class in kafka.protocol.group)
T
task_done() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
time_to_next_heartbeat() (kafka.coordinator.base.BaseCoordinator method)
(kafka.coordinator.heartbeat.Heartbeat method)
time_to_next_poll() (kafka.coordinator.consumer.ConsumerCoordinator method)
timestamp_type (kafka.protocol.message.Message attribute)
TIMESTAMP_TYPE_MASK (kafka.protocol.message.Message attribute)
topics (kafka.client.SimpleClient attribute)
(kafka.SimpleClient attribute)
topics() (kafka.cluster.ClusterMetadata method)
,
[1]
(kafka.KafkaConsumer method)
,
[1]
(kafka.consumer.KafkaConsumer method)
try_method_on_system_exit() (in module kafka.util)
ttl() (kafka.cluster.ClusterMetadata method)
,
[1]
U
UNJOINED (kafka.coordinator.base.MemberState attribute)
UnjoinedGroupException
UNKNOWN_MEMBER_ID (kafka.protocol.group.JoinGroupRequest_v0 attribute)
(kafka.protocol.group.JoinGroupRequest_v1 attribute)
(kafka.protocol.group.JoinGroupRequest_v2 attribute)
unsubscribe() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
update_consumer_offsets() (kafka.context.OffsetCommitContext method)
update_metadata() (kafka.cluster.ClusterMetadata method)
,
[1]
V
validate_crc() (kafka.protocol.message.Message method)
version (kafka.coordinator.assignors.roundrobin.RoundRobinPartitionAssignor attribute)
W
WeakMethod (class in kafka.util)
with_partitions() (kafka.cluster.ClusterMetadata method)
,
[1]
write_int_string() (in module kafka.util)
Read the Docs
v: 1.4.5
Versions
latest
stable
1.4.5
1.4.4
1.4.3
1.4.2
1.4.1
1.4.0
1.3.5
1.3.4
1.3.3
1.3.2
1.3.1
1.3.0
1.2.5
1.2.4
1.2.3
1.2.2
1.2.1
1.2.0
1.1.1
1.1.0
1.0.2
1.0.1
1.0.0
v0.9.5
v0.9.4
master
Downloads
pdf
htmlzip
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.