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) AuthenticationFailedError AuthenticationMethodNotSupported

B

BatchBuilder (class in aiokafka.producer.message_accumulator) beginning_offsets() (aiokafka.AIOKafkaConsumer method)

BrokerNotAvailableError BrokerResponseError

C

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

ConsumerRecord (class in aiokafka.structs) ConsumerStoppedError CoordinatorLoadInProgressError (in module aiokafka.errors) CoordinatorNotAvailableError (in module aiokafka.errors) CorrelationIdError CorruptRecordException 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) GroupAuthorizationFailedError

GroupCoordinator (class in aiokafka.consumer.group_coordinator) GroupCoordinatorNotAvailableError GroupIdNotFound GroupLoadInProgressError

H

headers (aiokafka.structs.ConsumerRecord attribute)

highwater() (aiokafka.AIOKafkaConsumer method)

I

IllegalArgumentError IllegalGenerationError IllegalOperation IllegalSaslStateError IllegalStateError IncompatibleBrokerVersion InconsistentGroupProtocolError InvalidCommitOffsetSizeError InvalidConfigurationError InvalidFetchRequestError InvalidFetchSessionEpoch InvalidGroupIdError InvalidMessageError (in module aiokafka.errors)

InvalidPartitionsError InvalidPrincipalType InvalidProducerEpoch InvalidProducerIdMapping InvalidReplicationAssignmentError InvalidReplicationFactorError InvalidRequestError InvalidRequiredAcksError InvalidSessionTimeoutError InvalidTimestampError InvalidTopicError InvalidTransactionTimeout InvalidTxnState

K

KafkaConfigurationError KafkaConnectionError KafkaError KafkaProtocolError

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

L

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

ListenerNotFound log_start_offset (aiokafka.structs.RecordMetadata attribute) LogDirNotFound

M

MessageSizeTooLargeError MetadataEmptyBrokerList module aiokafka.errors aiokafka.helpers aiokafka.structs

N

NoBrokersAvailable NodeNotReadyError NoError NonEmptyGroup NoOffsetForPartitionError

NotControllerError NotCoordinatorError (in module aiokafka.errors) NotCoordinatorForGroupError NotEnoughReplicasAfterAppendError NotEnoughReplicasError NotLeaderForPartitionError

O

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

OffsetOutOfRangeError 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) (aiokafka.structs.TopicPartition attribute) partitions_for() (aiokafka.AIOKafkaProducer method) partitions_for_topic() (aiokafka.AIOKafkaConsumer method) pause() (aiokafka.AIOKafkaConsumer method)

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

Q

QuotaViolationError

R

ReassignmentInProgress RebalanceInProgressError RecordListTooLargeError RecordMetadata (class in aiokafka.structs)

RecordTooLargeError ReplicaNotAvailableError RequestTimedOutError resume() (aiokafka.AIOKafkaConsumer method) RoundRobinPartitionAssignor (class in aiokafka.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) StaleControllerEpochError StaleLeaderEpochCodeError StaleMetadata 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) TooManyInFlightRequests topic (aiokafka.structs.ConsumerRecord attribute) (aiokafka.structs.RecordMetadata attribute) (aiokafka.structs.TopicPartition attribute)

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

U

UnknownError UnknownMemberIdError UnknownProducerId UnknownTopicOrPartitionError UnrecognizedBrokerVersion

unsubscribe() (aiokafka.AIOKafkaConsumer method) UnsupportedCodecError UnsupportedForMessageFormatError UnsupportedSaslMechanismError UnsupportedVersionError

V

value (aiokafka.structs.ConsumerRecord attribute)

VT (class in aiokafka.structs)