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) checksum (kafka.consumer.fetcher.ConsumerRecord attribute) (kafka.producer.future.RecordMetadata attribute) 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) ConsumerRecord (class in kafka.consumer.fetcher) 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) FutureRecordMetadata (class in kafka.producer.future)

G

get() (kafka.producer.future.FutureRecordMetadata method) 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) headers (kafka.consumer.fetcher.ConsumerRecord attribute)

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) key (kafka.consumer.fetcher.ConsumerRecord attribute)

L

last_activity (kafka.net.transport.KafkaTCPTransport property) LATEST (kafka.OffsetSpec attribute) LATEST_TIERED (kafka.OffsetSpec attribute) leader_epoch (kafka.consumer.fetcher.ConsumerRecord attribute) (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.consumer.fetcher.ConsumerRecord attribute) (kafka.OffsetAndMetadata attribute) (kafka.producer.future.RecordMetadata 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.consumer.fetcher.ConsumerRecord attribute) (kafka.producer.future.RecordMetadata attribute) (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) RecordMetadata (class in kafka.producer.future) 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) serialized_header_size (kafka.consumer.fetcher.ConsumerRecord attribute) (kafka.producer.future.RecordMetadata attribute) serialized_key_size (kafka.consumer.fetcher.ConsumerRecord attribute) (kafka.producer.future.RecordMetadata attribute)

serialized_value_size (kafka.consumer.fetcher.ConsumerRecord attribute) (kafka.producer.future.RecordMetadata attribute) 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

timestamp (kafka.consumer.fetcher.ConsumerRecord attribute) (kafka.producer.future.RecordMetadata attribute) timestamp_type (kafka.consumer.fetcher.ConsumerRecord attribute) topic (kafka.consumer.fetcher.ConsumerRecord attribute) (kafka.producer.future.RecordMetadata attribute) (kafka.TopicPartition attribute)

topic_id() (kafka.cluster.ClusterMetadata method) topic_name_for_id() (kafka.cluster.ClusterMetadata method) topic_partition (kafka.producer.future.RecordMetadata attribute) 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)

V

value (kafka.consumer.fetcher.ConsumerRecord attribute)

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)