Index

A

abort() (kafka.net.transport.KafkaTCPTransport method) abort_transaction() (kafka.KafkaAdminClient method) (kafka.KafkaProducer method) abortConnection() (kafka.net.transport.KafkaTCPTransport 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) api_versions() (kafka.KafkaAdminClient method) assign() (kafka.KafkaConsumer method) assignment() (kafka.KafkaConsumer method) AsyncConsumerRebalanceListener (class in kafka) 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) (kafka.net.manager.KafkaConnectionManager method) bootstrap_async() (kafka.net.manager.KafkaConnectionManager method) bootstrap_brokers() (kafka.cluster.ClusterMetadata method)

bootstrap_connected() (kafka.KafkaConsumer method) (kafka.KafkaProducer method) bootstrapped (kafka.net.manager.KafkaConnectionManager property) broker_metadata() (kafka.cluster.ClusterMetadata method) broker_version (kafka.net.connection.KafkaConnection property) (kafka.net.manager.KafkaConnectionManager property) brokers() (kafka.cluster.ClusterMetadata method)

C

call_soon() (kafka.net.manager.KafkaConnectionManager method) can_write_eof() (kafka.net.transport.KafkaTCPTransport method) close() (kafka.cluster.ClusterMetadata method) (kafka.Deserializer method) (kafka.KafkaAdminClient method) (kafka.KafkaConsumer method) (kafka.KafkaProducer method) (kafka.net.connection.KafkaConnection method) (kafka.net.manager.KafkaConnectionManager method) (kafka.net.transport.KafkaTCPTransport method) (kafka.Serializer method) close_future (kafka.net.connection.KafkaConnection property) close_idle_connections() (kafka.net.manager.KafkaConnectionManager method) closed (kafka.net.connection.KafkaConnection property) ClusterMetadata (class in kafka.cluster)

commit() (kafka.KafkaConsumer method) commit_async() (kafka.KafkaConsumer method) commit_transaction() (kafka.KafkaProducer method) committed() (kafka.KafkaConsumer method) connect() (kafka.net.inet.KafkaNetSocket method) connect_ex() (kafka.net.http_connect.HttpConnectProxy method) (kafka.net.inet.KafkaNetSocket method) (kafka.net.socks5.Socks5Proxy method) connection_delay() (kafka.net.manager.KafkaConnectionManager method) connection_lost() (kafka.net.connection.KafkaConnection method) connection_made() (kafka.net.connection.KafkaConnection method) ConsumerRebalanceListener (class in kafka) create_acls() (kafka.KafkaAdminClient method) create_connection() (in module kafka.net.inet) create_partitions() (kafka.KafkaAdminClient method) create_topics() (kafka.KafkaAdminClient method)

D

data_received() (kafka.net.connection.KafkaConnection method) DEFAULT_CONFIG (kafka.cluster.ClusterMetadata attribute) (kafka.net.connection.KafkaConnection attribute) (kafka.net.manager.KafkaConnectionManager attribute) DefaultSerializer (class in kafka) 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_producers() (kafka.KafkaAdminClient method) describe_topic_partitions() (kafka.KafkaAdminClient method) describe_topics() (kafka.KafkaAdminClient method) describe_transactions() (kafka.KafkaAdminClient method) describe_user_scram_credentials() (kafka.KafkaAdminClient method) deserialize() (kafka.DefaultSerializer method) (kafka.Deserializer method) (kafka.JsonSerializer method) Deserializer (class in kafka) dns_lookup() (kafka.net.http_connect.HttpConnectProxy method) (kafka.net.inet.KafkaNetSocket method) (kafka.net.socks5.Socks5Proxy method)

E

EARLIEST (kafka.OffsetSpec attribute) EARLIEST_LOCAL (kafka.OffsetSpec attribute)

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

F

fail_in_flight_requests() (kafka.net.connection.KafkaConnection method) failed_update() (kafka.cluster.ClusterMetadata method)

find_hanging_transactions() (kafka.KafkaAdminClient method) flush() (kafka.KafkaProducer method)

G

get_broker_version_data() (kafka.KafkaAdminClient method) get_connection() (kafka.net.manager.KafkaConnectionManager method) get_coordinator() (kafka.cluster.ClusterMetadata method) get_protocol() (kafka.net.transport.KafkaTCPTransport method) get_write_buffer_limits() (kafka.net.transport.KafkaTCPTransport method)

get_write_buffer_size() (kafka.net.transport.KafkaTCPTransport method) getHost() (kafka.net.transport.KafkaTCPTransport method) getPeer() (kafka.net.transport.KafkaTCPTransport method) getTcpKeepAlive() (kafka.net.transport.KafkaTCPTransport method) getTcpNoDelay() (kafka.net.transport.KafkaTCPTransport method) group_metadata() (kafka.KafkaConsumer method)

H

handshake() (kafka.net.transport.KafkaSSLTransport method) (kafka.net.transport.KafkaTCPTransport method)

highwater() (kafka.KafkaConsumer method) host_port() (kafka.net.transport.KafkaTCPTransport method) HttpConnectProxy (class in kafka.net.http_connect)

I

init_future (kafka.net.connection.KafkaConnection property) init_transactions() (kafka.KafkaProducer method) initialize() (kafka.net.connection.KafkaConnection method) is_bootstrap() (kafka.cluster.ClusterMetadata method)

is_closing() (kafka.net.transport.KafkaTCPTransport method) is_reading() (kafka.net.transport.KafkaTCPTransport method) is_replica_node() (kafka.cluster.ClusterMetadata method) IsolationLevel (class in kafka)

J

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

JsonSerializer (class in kafka)

K

kafka.net.connection module kafka.net.http_connect module kafka.net.inet module kafka.net.manager module kafka.net.socks5 module

kafka.net.transport module KafkaAdminClient (class in kafka) KafkaConnection (class in kafka.net.connection) KafkaConnectionManager (class in kafka.net.manager) KafkaConsumer (class in kafka) KafkaNetSocket (class in kafka.net.inet) KafkaProducer (class in kafka) KafkaSSLTransport (class in kafka.net.transport) KafkaTCPTransport (class in kafka.net.transport)

L

last_activity (kafka.net.transport.KafkaTCPTransport property) LATEST (kafka.OffsetSpec attribute) LATEST_TIERED (kafka.OffsetSpec attribute) 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) least_used_connections() (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) list_transactions() (kafka.KafkaAdminClient method) loseConnection() (kafka.net.transport.KafkaTCPTransport method) loseWriteConnection() (kafka.net.transport.KafkaTCPTransport method)

M

MAX_TIMESTAMP (kafka.OffsetSpec attribute) maybe_raise_auth_failure() (kafka.net.manager.KafkaConnectionManager method) metadata (kafka.OffsetAndMetadata attribute) metadata_refresh_in_progress (kafka.cluster.ClusterMetadata property) metadata_request() (kafka.cluster.ClusterMetadata method) metrics() (kafka.KafkaConsumer method) (kafka.KafkaProducer method)

module kafka.net.connection kafka.net.http_connect kafka.net.inet kafka.net.manager kafka.net.socks5 kafka.net.transport

N

need_update (kafka.cluster.ClusterMetadata property)

O

offset (kafka.OffsetAndMetadata attribute) OffsetAndMetadata (class in kafka) offsets_for_times() (kafka.KafkaConsumer method) OffsetSpec (class in kafka) on_partitions_assigned() (kafka.AsyncConsumerRebalanceListener method) (kafka.ConsumerRebalanceListener method)

on_partitions_lost() (kafka.AsyncConsumerRebalanceListener method) (kafka.ConsumerRebalanceListener method) on_partitions_revoked() (kafka.AsyncConsumerRebalanceListener method) (kafka.ConsumerRebalanceListener method)

P

partition (kafka.TopicPartition attribute) partition() (kafka.partitioner.Partitioner method) Partitioner (class in kafka.partitioner) 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) (kafka.net.connection.KafkaConnection method) pause_reading() (kafka.net.transport.KafkaTCPTransport method) pause_writing() (kafka.net.connection.KafkaConnection method) paused() (kafka.KafkaConsumer method) poll() (kafka.KafkaConsumer method) position() (kafka.KafkaConsumer method)

R

READ_COMMITTED (kafka.IsolationLevel attribute) READ_UNCOMMITTED (kafka.IsolationLevel attribute) refresh_backoff() (kafka.cluster.ClusterMetadata method) refresh_metadata() (kafka.cluster.ClusterMetadata method) register_class() (kafka.net.inet.KafkaNetSocket class method) remove_group_members() (kafka.KafkaAdminClient method) remove_listener() (kafka.cluster.ClusterMetadata method)

request_update() (kafka.cluster.ClusterMetadata method) reset_backoff() (kafka.net.manager.KafkaConnectionManager method) reset_configs() (kafka.KafkaAdminClient method) reset_group_offsets() (kafka.KafkaAdminClient method) resume() (kafka.KafkaConsumer method) resume_reading() (kafka.net.transport.KafkaTCPTransport method) resume_writing() (kafka.net.connection.KafkaConnection method) run() (kafka.net.manager.KafkaConnectionManager method)

S

sasl_enabled (kafka.net.connection.KafkaConnection property) SCHEMES (kafka.net.http_connect.HttpConnectProxy attribute) (kafka.net.socks5.Socks5Proxy attribute) seek() (kafka.KafkaConsumer method) seek_to_beginning() (kafka.KafkaConsumer method) seek_to_end() (kafka.KafkaConsumer method) send() (kafka.KafkaProducer method) (kafka.net.manager.KafkaConnectionManager method) send_buffered() (kafka.net.connection.KafkaConnection method) send_offsets_to_transaction() (kafka.KafkaProducer method) send_request() (kafka.net.connection.KafkaConnection method) serialize() (kafka.DefaultSerializer method) (kafka.JsonSerializer method) (kafka.Serializer method) Serializer (class in kafka)

set_protocol() (kafka.net.transport.KafkaTCPTransport method) set_topics() (kafka.cluster.ClusterMetadata method) set_write_buffer_limits() (kafka.net.transport.KafkaTCPTransport method) setTcpKeepAlive() (kafka.net.transport.KafkaTCPTransport method) setTcpNoDelay() (kafka.net.transport.KafkaTCPTransport method) sock_connect() (kafka.net.inet.KafkaNetSocket method) socket() (kafka.net.http_connect.HttpConnectProxy method) (kafka.net.inet.KafkaNetSocket method) (kafka.net.socks5.Socks5Proxy method) socket_connection_setup_timeout_ms() (kafka.net.manager.KafkaConnectionManager method) Socks5Proxy (class in kafka.net.socks5) ssl_enabled (kafka.net.manager.KafkaConnectionManager property) 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

unpause() (kafka.net.connection.KafkaConnection method) unsubscribe() (kafka.KafkaConsumer method) update_backoff() (kafka.net.manager.KafkaConnectionManager 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) write() (kafka.net.transport.KafkaTCPTransport method)

write_eof() (kafka.net.transport.KafkaTCPTransport method) writelines() (kafka.net.transport.KafkaTCPTransport method) writeSequence() (kafka.net.transport.KafkaTCPTransport method)