kafka-python
Usage Overview
KafkaConsumer
KafkaProducer
API
KafkaConsumer
KafkaProducer
KafkaClient
BrokerConnection
Simple Clients [deprecated]
SimpleConsumer (DEPRECATED)
SimpleProducer (DEPRECATED)
Asynchronous Mode
Synchronous Mode
KeyedProducer (DEPRECATED)
SimpleClient (DEPRECATED)
Install
Latest Release
Bleeding-Edge
Optional LZ4 install
Optional Snappy install
Install Development Libraries
Install Python Module
Tests
Unit tests
Integration tests
Compatibility
Support
License
Changelog
1.2.5 (July 15, 2016)
Bugfixes
1.2.4 (July 8, 2016)
Bugfixes
1.2.3 (July 2, 2016)
Patch Improvements
1.2.2 (June 21, 2016)
Bugfixes
1.2.1 (June 1, 2016)
Bugfixes
1.2.0 (May 24, 2016)
Support Kafka 0.10 Features
Consumers
Producers
Clients
Documentation
Internals
1.1.1 (Apr 26, 2016)
Bugfixes
1.1.0 (Apr 25, 2016)
Consumers
Producers
Clients
Documentation
Internals
1.0.2 (Mar 14, 2016)
Consumers
Producers
Clients
Documentation
Internals
1.0.1 (Feb 19, 2016)
Consumers
Producers
Clients
Documentation
Internals
1.0.0 (Feb 15, 2016)
Consumers
Producers
Clients
Documentation
Internals
0.9.5 (Dec 6, 2015)
Consumers
Producers
Clients
Documentation
Internals
0.9.4 (June 11, 2015)
Consumers
Producers
KafkaClient
Documentation
Internals
0.9.3 (Feb 3, 2015)
0.9.2 (Aug 26, 2014)
0.9.1 (Aug 10, 2014)
0.9.0 (Mar 21, 2014)
0.8.0
kafka-python
Docs
»
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
_
__call__() (kafka.util.WeakMethod method)
__enter__() (kafka.consumer.simple.FetchContext method)
(kafka.context.OffsetCommitContext method)
__exit__() (kafka.consumer.simple.FetchContext method)
(kafka.context.OffsetCommitContext method)
__getnewargs__() (kafka.conn.InFlightRequest method)
(kafka.consumer.multiprocess.Events method)
__getstate__() (kafka.conn.InFlightRequest method)
(kafka.consumer.multiprocess.Events method)
__iter__() (kafka.consumer.multiprocess.MultiProcessConsumer method)
(kafka.MultiProcessConsumer method)
(kafka.consumer.MultiProcessConsumer method)
__nonzero__() (kafka.context.OffsetCommitContext method)
__repr__() (kafka.conn.InFlightRequest method)
(kafka.consumer.multiprocess.Events method)
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_topic() (kafka.client.KafkaClient method)
API_KEY (kafka.protocol.admin.ApiVersionRequest_v0 attribute)
(kafka.protocol.admin.ApiVersionResponse_v0 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v0 attribute)
(kafka.protocol.admin.DescribeGroupsResponse_v0 attribute)
(kafka.protocol.admin.ListGroupsRequest_v0 attribute)
(kafka.protocol.admin.ListGroupsResponse_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorResponse_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v0 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v1 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v2 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v0 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v1 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v0 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v0 attribute)
(kafka.protocol.fetch.FetchRequest_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v2 attribute)
(kafka.protocol.fetch.FetchResponse_v0 attribute)
(kafka.protocol.fetch.FetchResponse_v1 attribute)
(kafka.protocol.fetch.FetchResponse_v2 attribute)
(kafka.protocol.group.HeartbeatRequest_v0 attribute)
(kafka.protocol.group.HeartbeatResponse_v0 attribute)
(kafka.protocol.group.JoinGroupRequest_v0 attribute)
(kafka.protocol.group.JoinGroupResponse_v0 attribute)
(kafka.protocol.group.LeaveGroupRequest_v0 attribute)
(kafka.protocol.group.LeaveGroupResponse_v0 attribute)
(kafka.protocol.group.SyncGroupRequest_v0 attribute)
(kafka.protocol.group.SyncGroupResponse_v0 attribute)
(kafka.protocol.metadata.MetadataRequest_v0 attribute)
(kafka.protocol.metadata.MetadataResponse_v0 attribute)
(kafka.protocol.offset.OffsetRequest_v0 attribute)
(kafka.protocol.offset.OffsetResponse_v0 attribute)
(kafka.protocol.produce.ProduceRequest_v0 attribute)
(kafka.protocol.produce.ProduceRequest_v1 attribute)
(kafka.protocol.produce.ProduceRequest_v2 attribute)
(kafka.protocol.produce.ProduceResponse_v0 attribute)
(kafka.protocol.produce.ProduceResponse_v1 attribute)
(kafka.protocol.produce.ProduceResponse_v2 attribute)
API_VERSION (kafka.protocol.admin.ApiVersionRequest_v0 attribute)
(kafka.protocol.admin.ApiVersionResponse_v0 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v0 attribute)
(kafka.protocol.admin.DescribeGroupsResponse_v0 attribute)
(kafka.protocol.admin.ListGroupsRequest_v0 attribute)
(kafka.protocol.admin.ListGroupsResponse_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorResponse_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v0 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v1 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v2 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v0 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v1 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v0 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v0 attribute)
(kafka.protocol.fetch.FetchRequest_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v2 attribute)
(kafka.protocol.fetch.FetchResponse_v0 attribute)
(kafka.protocol.fetch.FetchResponse_v1 attribute)
(kafka.protocol.fetch.FetchResponse_v2 attribute)
(kafka.protocol.group.HeartbeatRequest_v0 attribute)
(kafka.protocol.group.HeartbeatResponse_v0 attribute)
(kafka.protocol.group.JoinGroupRequest_v0 attribute)
(kafka.protocol.group.JoinGroupResponse_v0 attribute)
(kafka.protocol.group.LeaveGroupRequest_v0 attribute)
(kafka.protocol.group.LeaveGroupResponse_v0 attribute)
(kafka.protocol.group.SyncGroupRequest_v0 attribute)
(kafka.protocol.group.SyncGroupResponse_v0 attribute)
(kafka.protocol.metadata.MetadataRequest_v0 attribute)
(kafka.protocol.metadata.MetadataResponse_v0 attribute)
(kafka.protocol.offset.OffsetRequest_v0 attribute)
(kafka.protocol.offset.OffsetResponse_v0 attribute)
(kafka.protocol.produce.ProduceRequest_v0 attribute)
(kafka.protocol.produce.ProduceRequest_v1 attribute)
(kafka.protocol.produce.ProduceRequest_v2 attribute)
(kafka.protocol.produce.ProduceResponse_v0 attribute)
(kafka.protocol.produce.ProduceResponse_v1 attribute)
(kafka.protocol.produce.ProduceResponse_v2 attribute)
ApiVersionRequest_v0 (class in kafka.protocol.admin)
ApiVersionResponse_v0 (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]
AutoCommitTask (class in kafka.coordinator.consumer)
B
BaseCoordinator (class in kafka.coordinator.base)
blacked_out() (kafka.BrokerConnection method)
,
[1]
(kafka.conn.BrokerConnection method)
BrokerConnection (class in kafka)
,
[1]
(class in kafka.conn)
Bytes (class in kafka.protocol.types)
C
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.BrokerConnection method)
,
[1]
(kafka.KafkaConsumer method)
,
[1]
(kafka.KafkaProducer method)
,
[1]
(kafka.SimpleClient method)
(kafka.client.KafkaClient method)
(kafka.client.SimpleClient method)
(kafka.conn.BrokerConnection method)
(kafka.conn.KafkaConnection method)
(kafka.consumer.KafkaConsumer method)
(kafka.coordinator.base.BaseCoordinator method)
(kafka.coordinator.consumer.ConsumerCoordinator method)
(kafka.producer.KafkaProducer method)
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)
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.client.KafkaClient 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)
coordinator_dead() (kafka.coordinator.base.BaseCoordinator method)
coordinator_unknown() (kafka.coordinator.base.BaseCoordinator method)
copy() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
(kafka.conn.KafkaConnection method)
correlation_id (kafka.conn.InFlightRequest attribute)
crc32() (in module kafka.util)
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_snappy_message() (in module kafka)
(in module kafka.protocol.legacy)
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.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_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.KafkaConsumer attribute)
(kafka.conn.BrokerConnection attribute)
(kafka.consumer.KafkaConsumer attribute)
(kafka.coordinator.base.BaseCoordinator attribute)
(kafka.coordinator.consumer.ConsumerCoordinator attribute)
(kafka.coordinator.heartbeat.Heartbeat attribute)
DEFAULT_GENERATION_ID (kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
DEFAULT_RETENTION_TIME (kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
DEFAULTS (kafka.protocol.offset.OffsetRequest_v0 attribute)
DescribeGroupsRequest_v0 (class in kafka.protocol.admin)
DescribeGroupsResponse_v0 (class in kafka.protocol.admin)
disable() (kafka.coordinator.base.HeartbeatTask method)
(kafka.coordinator.consumer.AutoCommitTask method)
DISCONNECTED (kafka.conn.ConnectionStates attribute)
disconnected() (kafka.BrokerConnection method)
,
[1]
(kafka.conn.BrokerConnection method)
DISCONNECTING (kafka.conn.ConnectionStates attribute)
E
EARLIEST (kafka.protocol.offset.OffsetResetStrategy attribute)
enable() (kafka.coordinator.consumer.AutoCommitTask 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.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_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)
ensure_active_group() (kafka.coordinator.base.BaseCoordinator method)
ensure_coordinator_known() (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)
F
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)
FetchResponse_v0 (class in kafka.protocol.fetch)
FetchResponse_v1 (class in kafka.protocol.fetch)
FetchResponse_v2 (class in kafka.protocol.fetch)
flush() (kafka.KafkaProducer method)
,
[1]
(kafka.producer.KafkaProducer method)
future (kafka.conn.InFlightRequest attribute)
G
get_connected_socket() (kafka.conn.KafkaConnection 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)
GroupCoordinatorRequest_v0 (class in kafka.protocol.commit)
GroupCoordinatorResponse_v0 (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)
HeartbeatResponse_v0 (class in kafka.protocol.group)
HeartbeatTask (class in kafka.coordinator.base)
highwater() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
I
in_flight_request_count() (kafka.client.KafkaClient method)
InFlightRequest (class in kafka.conn)
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_ready() (kafka.client.KafkaClient method)
ITEM (kafka.protocol.message.MessageSet attribute)
J
JoinGroupRequest_v0 (class in kafka.protocol.group)
JoinGroupResponse_v0 (class in kafka.protocol.group)
K
kafka (module)
kafka.client (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)
KafkaClient (class in kafka)
(class in kafka.client)
KafkaConnection (class in kafka.conn)
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)
least_loaded_node() (kafka.client.KafkaClient method)
LeaveGroupRequest_v0 (class in kafka.protocol.group)
LeaveGroupResponse_v0 (class in kafka.protocol.group)
LegacyPartitioner (class in kafka.partitioner)
(class in kafka.partitioner.hashed)
ListGroupsRequest_v0 (class in kafka.protocol.admin)
ListGroupsResponse_v0 (class in kafka.protocol.admin)
load_metadata_for_topics() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
lz4_decode() (in module kafka.codec)
lz4_decode_old_kafka() (in module kafka.codec)
lz4_encode() (in module kafka.codec)
lz4_encode_old_kafka() (in module kafka.codec)
M
mark() (kafka.context.OffsetCommitContext method)
MemberAssignment (class in kafka.protocol.group)
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)
MetadataResponse_v0 (class in kafka.protocol.metadata)
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)
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)
OffsetCommitResponse_v0 (class in kafka.protocol.commit)
OffsetCommitResponse_v1 (class in kafka.protocol.commit)
OffsetCommitResponse_v2 (class in kafka.protocol.commit)
OffsetFetchRequest_v0 (class in kafka.protocol.commit)
OffsetFetchRequest_v1 (class in kafka.protocol.commit)
OffsetFetchResponse_v0 (class in kafka.protocol.commit)
OffsetFetchResponse_v1 (class in kafka.protocol.commit)
OffsetRequest_v0 (class in kafka.protocol.offset)
OffsetResetStrategy (class in kafka.protocol.offset)
OffsetResponse_v0 (class in kafka.protocol.offset)
offsets() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
on_assignment() (kafka.coordinator.assignors.abstract.AbstractPartitionAssignor method)
(kafka.coordinator.assignors.roundrobin.RoundRobinPartitionAssignor class method)
P
PartialMessage (class in kafka.protocol.message)
partition() (kafka.partitioner.base.Partitioner method)
(kafka.RoundRobinPartitioner method)
(kafka.partitioner.LegacyPartitioner method)
(kafka.partitioner.Murmur2Partitioner method)
(kafka.partitioner.RoundRobinPartitioner method)
(kafka.partitioner.hashed.LegacyPartitioner method)
(kafka.partitioner.hashed.Murmur2Partitioner method)
(kafka.partitioner.roundrobin.RoundRobinPartitioner method)
Partitioner (class in kafka.partitioner.base)
partitions_for() (kafka.KafkaProducer method)
,
[1]
(kafka.producer.KafkaProducer method)
partitions_for_topic() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
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)
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)
ProduceResponse_v0 (class in kafka.protocol.produce)
ProduceResponse_v1 (class in kafka.protocol.produce)
ProduceResponse_v2 (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_int_string() (in module kafka.util)
read_short_string() (in module kafka.util)
ready() (kafka.client.KafkaClient method)
received_heartbeat() (kafka.coordinator.heartbeat.Heartbeat method)
recv() (kafka.BrokerConnection method)
,
[1]
(kafka.conn.BrokerConnection method)
(kafka.conn.KafkaConnection method)
ReentrantTimer (class in kafka.util)
refresh_committed_offsets_if_needed() (kafka.coordinator.consumer.ConsumerCoordinator method)
reinit() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
(kafka.conn.KafkaConnection method)
relative_unpack() (in module kafka.util)
repr() (kafka.protocol.abstract.AbstractType class method)
(kafka.protocol.message.MessageSet class method)
(kafka.protocol.types.Array method)
(kafka.protocol.types.Schema method)
request (kafka.conn.InFlightRequest attribute)
RequestHeader (class in kafka.protocol.api)
reset() (kafka.coordinator.base.HeartbeatTask method)
reset_all_metadata() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
reset_partition_offset() (kafka.consumer.simple.SimpleConsumer method)
(kafka.SimpleConsumer method)
(kafka.consumer.SimpleConsumer method)
reset_session_timeout() (kafka.coordinator.heartbeat.Heartbeat method)
reset_topic_metadata() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
response_type (kafka.conn.InFlightRequest attribute)
RESPONSE_TYPE (kafka.protocol.admin.ApiVersionRequest_v0 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v0 attribute)
(kafka.protocol.admin.ListGroupsRequest_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v0 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v0 attribute)
(kafka.protocol.fetch.FetchRequest_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v2 attribute)
(kafka.protocol.group.HeartbeatRequest_v0 attribute)
(kafka.protocol.group.JoinGroupRequest_v0 attribute)
(kafka.protocol.group.LeaveGroupRequest_v0 attribute)
(kafka.protocol.group.SyncGroupRequest_v0 attribute)
(kafka.protocol.metadata.MetadataRequest_v0 attribute)
(kafka.protocol.offset.OffsetRequest_v0 attribute)
(kafka.protocol.produce.ProduceRequest_v0 attribute)
(kafka.protocol.produce.ProduceRequest_v1 attribute)
(kafka.protocol.produce.ProduceRequest_v2 attribute)
resume() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
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)
S
schedule() (kafka.client.KafkaClient method)
Schema (class in kafka.protocol.types)
SCHEMA (kafka.protocol.admin.ApiVersionRequest_v0 attribute)
(kafka.protocol.admin.ApiVersionResponse_v0 attribute)
(kafka.protocol.admin.DescribeGroupsRequest_v0 attribute)
(kafka.protocol.admin.DescribeGroupsResponse_v0 attribute)
(kafka.protocol.admin.ListGroupsRequest_v0 attribute)
(kafka.protocol.admin.ListGroupsResponse_v0 attribute)
(kafka.protocol.api.RequestHeader attribute)
(kafka.protocol.commit.GroupCoordinatorRequest_v0 attribute)
(kafka.protocol.commit.GroupCoordinatorResponse_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v0 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v1 attribute)
(kafka.protocol.commit.OffsetCommitRequest_v2 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v0 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v1 attribute)
(kafka.protocol.commit.OffsetCommitResponse_v2 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v0 attribute)
(kafka.protocol.commit.OffsetFetchRequest_v1 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v0 attribute)
(kafka.protocol.commit.OffsetFetchResponse_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v0 attribute)
(kafka.protocol.fetch.FetchRequest_v1 attribute)
(kafka.protocol.fetch.FetchRequest_v2 attribute)
(kafka.protocol.fetch.FetchResponse_v0 attribute)
(kafka.protocol.fetch.FetchResponse_v1 attribute)
(kafka.protocol.fetch.FetchResponse_v2 attribute)
(kafka.protocol.group.HeartbeatRequest_v0 attribute)
(kafka.protocol.group.HeartbeatResponse_v0 attribute)
(kafka.protocol.group.JoinGroupRequest_v0 attribute)
(kafka.protocol.group.JoinGroupResponse_v0 attribute)
(kafka.protocol.group.LeaveGroupRequest_v0 attribute)
(kafka.protocol.group.LeaveGroupResponse_v0 attribute)
(kafka.protocol.group.MemberAssignment attribute)
(kafka.protocol.group.ProtocolMetadata attribute)
(kafka.protocol.group.SyncGroupRequest_v0 attribute)
(kafka.protocol.group.SyncGroupResponse_v0 attribute)
(kafka.protocol.message.Message attribute)
(kafka.protocol.metadata.MetadataRequest_v0 attribute)
(kafka.protocol.metadata.MetadataResponse_v0 attribute)
(kafka.protocol.offset.OffsetRequest_v0 attribute)
(kafka.protocol.offset.OffsetResponse_v0 attribute)
(kafka.protocol.produce.ProduceRequest_v0 attribute)
(kafka.protocol.produce.ProduceRequest_v1 attribute)
(kafka.protocol.produce.ProduceRequest_v2 attribute)
(kafka.protocol.produce.ProduceResponse_v0 attribute)
(kafka.protocol.produce.ProduceResponse_v1 attribute)
(kafka.protocol.produce.ProduceResponse_v2 attribute)
(kafka.protocol.struct.Struct attribute)
SCHEMAS (kafka.protocol.message.Message 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.conn.KafkaConnection 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_messages() (kafka.KeyedProducer method)
(kafka.SimpleProducer method)
(kafka.producer.KeyedProducer method)
(kafka.producer.SimpleProducer method)
(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_produce_request() (kafka.client.SimpleClient method)
(kafka.SimpleClient method)
sent_heartbeat() (kafka.coordinator.heartbeat.Heartbeat method)
session_expired() (kafka.coordinator.heartbeat.Heartbeat 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)
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)
SyncGroupResponse_v0 (class in kafka.protocol.group)
T
task_done() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
timestamp (kafka.conn.InFlightRequest attribute)
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.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
try_method_on_system_exit() (in module kafka.util)
ttl() (kafka.coordinator.heartbeat.Heartbeat method)
U
UNKNOWN_MEMBER_ID (kafka.protocol.group.JoinGroupRequest_v0 attribute)
unschedule() (kafka.client.KafkaClient method)
unsubscribe() (kafka.consumer.KafkaConsumer method)
(kafka.KafkaConsumer method)
,
[1]
update_consumer_offsets() (kafka.context.OffsetCommitContext method)
V
validate_crc() (kafka.protocol.message.Message method)
version (kafka.coordinator.assignors.roundrobin.RoundRobinPartitionAssignor attribute)
W
WeakMethod (class in kafka.util)
write_int_string() (in module kafka.util)
write_short_string() (in module kafka.util)