Index

A

AbstractTokenProvider (class in aiokafka.abc) aiokafka.errors module aiokafka.helpers module

aiokafka.structs module AIOKafkaConsumer (class in aiokafka) AIOKafkaProducer (class in aiokafka) assign() (aiokafka.AIOKafkaConsumer method) assignment() (aiokafka.AIOKafkaConsumer method)

B

BatchBuilder (class in aiokafka.producer.message_accumulator)

beginning_offsets() (aiokafka.AIOKafkaConsumer method)

C

checksum (aiokafka.structs.ConsumerRecord attribute) commit() (aiokafka.AIOKafkaConsumer method) CommitFailedError (class in aiokafka.errors) committed() (aiokafka.AIOKafkaConsumer method) ConcurrentTransactions ConsumerRebalanceListener (class in aiokafka.abc) ConsumerRecord (class in aiokafka.structs)

ConsumerStoppedError CoordinatorLoadInProgressError CoordinatorNotAvailableError CorruptRecordException (class in aiokafka.errors) (class in kafka.errors) create_batch() (aiokafka.AIOKafkaProducer method) create_ssl_context() (in module aiokafka.helpers)

D

DelegationTokenAuthDisabled DelegationTokenAuthorizationFailed DelegationTokenExpired

DelegationTokenNotFound DelegationTokenOwnerMismatch DelegationTokenRequestNotAllowed DuplicateSequenceNumber

E

end_offsets() (aiokafka.AIOKafkaConsumer method)

extensions() (aiokafka.abc.AbstractTokenProvider method)

F

FetchSessionIdNotFound

flush() (aiokafka.AIOKafkaProducer method)

G

getmany() (aiokafka.AIOKafkaConsumer method) getone() (aiokafka.AIOKafkaConsumer method) GroupCoordinator (class in aiokafka.consumer.group_coordinator)

GroupCoordinatorNotAvailableError (in module aiokafka.errors) GroupIdNotFound GroupLoadInProgressError (in module aiokafka.errors)

H

headers (aiokafka.structs.ConsumerRecord attribute)

highwater() (aiokafka.AIOKafkaConsumer method)

I

IllegalOperation IllegalStateError (class in aiokafka.errors) InvalidFetchSessionEpoch InvalidMessageError (in module aiokafka.errors)

InvalidPrincipalType InvalidProducerEpoch InvalidProducerIdMapping InvalidTransactionTimeout InvalidTxnState

K

kafka.oauth.abstract module KafkaError (class in aiokafka.errors)

KafkaStorageError KafkaTimeoutError (class in aiokafka.errors) key (aiokafka.structs.ConsumerRecord attribute) KT (class in aiokafka.structs)

L

last_poll_timestamp() (aiokafka.AIOKafkaConsumer method) last_stable_offset() (aiokafka.AIOKafkaConsumer method)

ListenerNotFound log_start_offset (aiokafka.structs.RecordMetadata attribute) LogDirNotFound

M

module aiokafka.errors aiokafka.helpers aiokafka.structs kafka.oauth.abstract

N

NonEmptyGroup NoOffsetForPartitionError NotCoordinatorError

NotCoordinatorForGroupError (in module aiokafka.errors) NotEnoughReplicasAfterAppendError (class in aiokafka.errors) NotEnoughReplicasError (class in aiokafka.errors)

O

offset (aiokafka.structs.ConsumerRecord attribute) (aiokafka.structs.OffsetAndTimestamp attribute) (aiokafka.structs.RecordMetadata attribute) OffsetAndTimestamp (class in aiokafka.structs) OffsetOutOfRangeError (class in aiokafka.errors)

offsets_for_times() (aiokafka.AIOKafkaConsumer method) on_partitions_assigned() (aiokafka.abc.ConsumerRebalanceListener method) on_partitions_revoked() (aiokafka.abc.ConsumerRebalanceListener method) OperationNotAttempted OutOfOrderSequenceNumber

P

partition (aiokafka.structs.ConsumerRecord attribute) (aiokafka.structs.RecordMetadata attribute) (kafka.structs.TopicPartition attribute) partitions_for() (aiokafka.AIOKafkaProducer method) partitions_for_topic() (aiokafka.AIOKafkaConsumer method)

pause() (aiokafka.AIOKafkaConsumer method) paused() (aiokafka.AIOKafkaConsumer method) position() (aiokafka.AIOKafkaConsumer method) ProducerClosed ProduceRequest (in module kafka.protocol.produce) ProducerFenced

R

ReassignmentInProgress RecordMetadata (class in aiokafka.structs) RecordTooLargeError

RequestTimedOutError (class in aiokafka.errors) resume() (aiokafka.AIOKafkaConsumer method) RoundRobinPartitionAssignor (class in kafka.coordinator.assignors.roundrobin)

S

SaslAuthenticationFailed SecurityDisabled seek() (aiokafka.AIOKafkaConsumer method) seek_to_beginning() (aiokafka.AIOKafkaConsumer method) seek_to_committed() (aiokafka.AIOKafkaConsumer method) seek_to_end() (aiokafka.AIOKafkaConsumer method) send() (aiokafka.AIOKafkaProducer method) send_and_wait() (aiokafka.AIOKafkaProducer method)

send_batch() (aiokafka.AIOKafkaProducer method) serialized_key_size (aiokafka.structs.ConsumerRecord attribute) serialized_value_size (aiokafka.structs.ConsumerRecord attribute) start() (aiokafka.AIOKafkaConsumer method) (aiokafka.AIOKafkaProducer method) stop() (aiokafka.AIOKafkaConsumer method) (aiokafka.AIOKafkaProducer method) subscribe() (aiokafka.AIOKafkaConsumer method) subscription() (aiokafka.AIOKafkaConsumer method)

T

timestamp (aiokafka.structs.ConsumerRecord attribute) (aiokafka.structs.OffsetAndTimestamp attribute) (aiokafka.structs.RecordMetadata attribute) timestamp_type (aiokafka.structs.ConsumerRecord attribute) (aiokafka.structs.RecordMetadata attribute) token() (aiokafka.abc.AbstractTokenProvider method) topic (aiokafka.structs.ConsumerRecord attribute) (aiokafka.structs.RecordMetadata attribute) (kafka.structs.TopicPartition attribute)

topic_partition (aiokafka.structs.RecordMetadata attribute) TopicAuthorizationFailedError (class in aiokafka.errors) TopicPartition (class in kafka.structs) topics() (aiokafka.AIOKafkaConsumer method) transaction() (aiokafka.AIOKafkaProducer method) TransactionalIdAuthorizationFailed TransactionCoordinatorFenced

U

UnknownProducerId

unsubscribe() (aiokafka.AIOKafkaConsumer method) UnsupportedVersionError (class in aiokafka.errors)

V

value (aiokafka.structs.ConsumerRecord attribute)

VT (class in aiokafka.structs)