Index

A

abort_transaction() (kafka.KafkaProducer method) add_coordinator() (kafka.cluster.ClusterMetadata method) add_listener() (kafka.cluster.ClusterMetadata method) add_topic() (kafka.cluster.ClusterMetadata method) alter_configs() (kafka.KafkaAdminClient method) alter_group_offsets() (kafka.KafkaAdminClient method) alter_partition_reassignments() (kafka.KafkaAdminClient method)

alter_replica_log_dirs() (kafka.KafkaAdminClient method) alter_user_scram_credentials() (kafka.KafkaAdminClient method) assign() (kafka.KafkaConsumer method) assignment() (kafka.KafkaConsumer method) attach() (kafka.cluster.ClusterMetadata method) auth_failure() (kafka.net.manager.KafkaConnectionManager method) available_partitions_for_topic() (kafka.cluster.ClusterMetadata method)

B

begin_transaction() (kafka.KafkaProducer method) beginning_offsets() (kafka.KafkaConsumer method) bootstrap() (kafka.KafkaConsumer method) bootstrap_brokers() (kafka.cluster.ClusterMetadata method)

bootstrap_connected() (kafka.KafkaConsumer method) (kafka.KafkaProducer method) broker_metadata() (kafka.cluster.ClusterMetadata method) brokers() (kafka.cluster.ClusterMetadata method)

C

call_soon() (kafka.net.manager.KafkaConnectionManager method) close() (kafka.KafkaAdminClient method) (kafka.KafkaConsumer method) (kafka.KafkaProducer method) ClusterMetadata (class in kafka.cluster) commit() (kafka.KafkaConsumer method) commit_async() (kafka.KafkaConsumer method) commit_transaction() (kafka.KafkaProducer method)

committed() (kafka.KafkaConsumer method) connection_delay() (kafka.net.manager.KafkaConnectionManager method) connection_lost() (kafka.net.connection.KafkaConnection method) connection_made() (kafka.net.connection.KafkaConnection method) coordinator_for_group() (kafka.cluster.ClusterMetadata method) create_acls() (kafka.KafkaAdminClient method) create_partitions() (kafka.KafkaAdminClient method) create_topics() (kafka.KafkaAdminClient method)

D

data_received() (kafka.net.connection.KafkaConnection method) delete_acls() (kafka.KafkaAdminClient method) delete_group_offsets() (kafka.KafkaAdminClient method) delete_groups() (kafka.KafkaAdminClient method) delete_records() (kafka.KafkaAdminClient method) delete_topics() (kafka.KafkaAdminClient method) describe_acls() (kafka.KafkaAdminClient method) describe_cluster() (kafka.KafkaAdminClient method)

describe_configs() (kafka.KafkaAdminClient method) describe_features() (kafka.KafkaAdminClient method) describe_groups() (kafka.KafkaAdminClient method) describe_log_dirs() (kafka.KafkaAdminClient method) describe_metadata_quorum() (kafka.KafkaAdminClient method) describe_topic_partitions() (kafka.KafkaAdminClient method) describe_topics() (kafka.KafkaAdminClient method) describe_user_scram_credentials() (kafka.KafkaAdminClient method)

E

elect_leaders() (kafka.KafkaAdminClient method)

end_offsets() (kafka.KafkaConsumer method) eof_received() (kafka.net.connection.KafkaConnection method)

F

failed_update() (kafka.cluster.ClusterMetadata method)

flush() (kafka.KafkaProducer method)

G

get_broker_version_data() (kafka.KafkaAdminClient method)

group_metadata() (kafka.KafkaConsumer method)

H

highwater() (kafka.KafkaConsumer method)

I

init_transactions() (kafka.KafkaProducer method)

is_replica_node() (kafka.cluster.ClusterMetadata method)

K

KafkaAdminClient (class in kafka) KafkaConnection (class in kafka.net.connection)

KafkaConnectionManager (class in kafka.net.manager) KafkaConsumer (class in kafka) KafkaProducer (class in kafka)

L

leader_epoch (kafka.OffsetAndMetadata attribute) leader_epoch_for_partition() (kafka.cluster.ClusterMetadata method) leader_for_partition() (kafka.cluster.ClusterMetadata method) least_loaded_node() (kafka.net.manager.KafkaConnectionManager method) list_config_resources() (kafka.KafkaAdminClient method)

list_group_offsets() (kafka.KafkaAdminClient method) list_groups() (kafka.KafkaAdminClient method) list_partition_offsets() (kafka.KafkaAdminClient method) list_partition_reassignments() (kafka.KafkaAdminClient method) list_topics() (kafka.KafkaAdminClient method)

M

maybe_raise_auth_failure() (kafka.net.manager.KafkaConnectionManager method) metadata (kafka.OffsetAndMetadata attribute)

metadata_refresh_in_progress (kafka.cluster.ClusterMetadata property) metrics() (kafka.KafkaConsumer method) (kafka.KafkaProducer method)

O

offset (kafka.OffsetAndMetadata attribute)

OffsetAndMetadata (class in kafka) offsets_for_times() (kafka.KafkaConsumer method)

P

partition (kafka.TopicPartition attribute) partitions_for() (kafka.KafkaProducer method) partitions_for_broker() (kafka.cluster.ClusterMetadata method) partitions_for_topic() (kafka.cluster.ClusterMetadata method) (kafka.KafkaConsumer method)

pause() (kafka.KafkaConsumer method) pause_writing() (kafka.net.connection.KafkaConnection method) paused() (kafka.KafkaConsumer method) poll() (kafka.KafkaConsumer method) position() (kafka.KafkaConsumer method)

R

refresh_backoff() (kafka.cluster.ClusterMetadata method) refresh_metadata() (kafka.cluster.ClusterMetadata method) remove_group_members() (kafka.KafkaAdminClient method) remove_listener() (kafka.cluster.ClusterMetadata method) request_update() (kafka.cluster.ClusterMetadata method)

reset_configs() (kafka.KafkaAdminClient method) reset_group_offsets() (kafka.KafkaAdminClient method) resume() (kafka.KafkaConsumer method) resume_writing() (kafka.net.connection.KafkaConnection method) run() (kafka.net.manager.KafkaConnectionManager method)

S

seek() (kafka.KafkaConsumer method) seek_to_beginning() (kafka.KafkaConsumer method) seek_to_end() (kafka.KafkaConsumer method) send() (kafka.KafkaProducer method)

send_offsets_to_transaction() (kafka.KafkaProducer method) set_topics() (kafka.cluster.ClusterMetadata method) start_refresh_loop() (kafka.cluster.ClusterMetadata method) subscribe() (kafka.KafkaConsumer method) subscription() (kafka.KafkaConsumer method)

T

topic (kafka.TopicPartition attribute) topic_id() (kafka.cluster.ClusterMetadata method) topic_name_for_id() (kafka.cluster.ClusterMetadata method)

TopicPartition (class in kafka) topics() (kafka.cluster.ClusterMetadata method) (kafka.KafkaConsumer method) ttl() (kafka.cluster.ClusterMetadata method)

U

unsubscribe() (kafka.KafkaConsumer method) update_features() (kafka.KafkaAdminClient method)

update_metadata() (kafka.cluster.ClusterMetadata method) update_partition_leader() (kafka.cluster.ClusterMetadata method)

W

wait_for() (kafka.net.manager.KafkaConnectionManager method)

wait_for_topics() (kafka.KafkaAdminClient method)