Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
A
afkak (module)
afkak.CODEC_GZIP (in module afkak)
afkak.CODEC_LZ4 (in module afkak)
afkak.CODEC_NONE (in module afkak)
afkak.CODEC_SNAPPY (in module afkak)
afkak.common (module)
afkak.OFFSET_COMMITTED (in module afkak)
afkak.OFFSET_EARLIEST (in module afkak)
afkak.OFFSET_LATEST (in module afkak)
B
BrokerMetadata (class in afkak.common)
BrokerNotAvailableError
BrokerResponseError
BufferUnderflowError
C
CancelledError
ChecksumError
ClientError
clientId (afkak.KafkaClient attribute)
clock (afkak.KafkaClient attribute)
close() (afkak.KafkaClient method)
ClusterAuthorizationFailed
commit() (afkak.Consumer method)
ConcurrentTransactions
ConnectionError
Consumer (class in afkak)
consumer_group_to_brokers (afkak.KafkaClient attribute)
ConsumerCoordinatorNotAvailableError (in module afkak.common)
ConsumerFetchSizeTooSmall
ConsumerMetadataResponse (class in afkak.common)
CoordinatorLoadInProgress
CoordinatorNotAvailable
CorruptMessage
create_message() (in module afkak)
create_message_set() (in module afkak)
D
DEFAULT_FETCH_MIN_BYTES (afkak.KafkaClient attribute)
DEFAULT_FETCH_SERVER_WAIT_MSECS (afkak.KafkaClient attribute)
DEFAULT_REPLICAS_ACK_MSECS (afkak.KafkaClient attribute)
DEFAULT_REQUEST_TIMEOUT_MSECS (afkak.KafkaClient attribute)
deferred (afkak.common.SendRequest attribute)
DelegationTokenAuthDisabled
DelegationTokenAuthorizationFailed
DelegationTokenExpired
DelegationTokenNotFound
DelegationTokenOwnerMismatch
DelegationTokenRequestNotAllowed
DuplicateRequestError
DuplicateSequenceNumber
E
errno (afkak.common.BrokerNotAvailableError attribute)
(afkak.common.ClusterAuthorizationFailed attribute)
(afkak.common.ConcurrentTransactions attribute)
(afkak.common.CoordinatorLoadInProgress attribute)
(afkak.common.CoordinatorNotAvailable attribute)
(afkak.common.CorruptMessage attribute)
(afkak.common.DelegationTokenAuthDisabled attribute)
(afkak.common.DelegationTokenAuthorizationFailed attribute)
(afkak.common.DelegationTokenExpired attribute)
(afkak.common.DelegationTokenNotFound attribute)
(afkak.common.DelegationTokenOwnerMismatch attribute)
(afkak.common.DelegationTokenRequestNotAllowed attribute)
(afkak.common.DuplicateSequenceNumber attribute)
(afkak.common.FetchSessionIdNotFound attribute)
(afkak.common.GroupAuthorizationFailed attribute)
(afkak.common.GroupIdNotFound attribute)
(afkak.common.IllegalGeneration attribute)
(afkak.common.IllegalSaslState attribute)
(afkak.common.InconsistentGroupProtocol attribute)
(afkak.common.InvalidCommitOffsetSize attribute)
(afkak.common.InvalidConfig attribute)
(afkak.common.InvalidFetchRequestError attribute)
(afkak.common.InvalidFetchSessionEpoch attribute)
(afkak.common.InvalidGroupId attribute)
(afkak.common.InvalidPartitions attribute)
(afkak.common.InvalidPrincipalType attribute)
(afkak.common.InvalidProducerEpoch attribute)
(afkak.common.InvalidProducerIdMapping attribute)
(afkak.common.InvalidReplicaAssignment attribute)
(afkak.common.InvalidReplicationFactor attribute)
(afkak.common.InvalidRequest attribute)
(afkak.common.InvalidRequiredAcks attribute)
(afkak.common.InvalidSessionTimeout attribute)
(afkak.common.InvalidTimestamp attribute)
(afkak.common.InvalidTopic attribute)
(afkak.common.InvalidTransactionTimeout attribute)
(afkak.common.InvalidTxnState attribute)
(afkak.common.KafkaStorageError attribute)
(afkak.common.LeaderNotAvailableError attribute)
(afkak.common.ListenerNotFound attribute)
(afkak.common.LogDirNotFound attribute)
(afkak.common.MessageSizeTooLargeError attribute)
(afkak.common.NetworkException attribute)
(afkak.common.NonEmptyGroup attribute)
(afkak.common.NotController attribute)
(afkak.common.NotCoordinator attribute)
(afkak.common.NotEnoughReplicas attribute)
(afkak.common.NotEnoughReplicasAfterAppend attribute)
(afkak.common.NotLeaderForPartitionError attribute)
(afkak.common.OffsetMetadataTooLargeError attribute)
(afkak.common.OffsetOutOfRangeError attribute)
(afkak.common.OperationNotAttempted attribute)
(afkak.common.OutOfOrderSequenceNumber attribute)
(afkak.common.PolicyViolation attribute)
(afkak.common.ReassignmentInProgress attribute)
(afkak.common.RebalanceInProgress attribute)
(afkak.common.RecordListTooLarge attribute)
(afkak.common.ReplicaNotAvailableError attribute)
(afkak.common.RequestTimedOutError attribute)
(afkak.common.SaslAuthenticationFailed attribute)
(afkak.common.SecurityDisabled attribute)
(afkak.common.StaleControllerEpochError attribute)
(afkak.common.TopicAlreadyExists attribute)
(afkak.common.TopicAuthorizationFailed attribute)
(afkak.common.TransactionCoordinatorFenced attribute)
(afkak.common.TransactionalIdAuthorizationFailed attribute)
(afkak.common.UnknownError attribute)
(afkak.common.UnknownMemberId attribute)
(afkak.common.UnknownProducerId attribute)
(afkak.common.UnknownTopicOrPartitionError attribute)
(afkak.common.UnsupportedForMessageFormat attribute)
(afkak.common.UnsupportedSaslMechanism attribute)
(afkak.common.UnsupportedVersion attribute)
errnos (afkak.common.BrokerResponseError attribute)
error (afkak.common.ConsumerMetadataResponse attribute)
(afkak.common.FetchResponse attribute)
(afkak.common.OffsetCommitResponse attribute)
(afkak.common.OffsetFetchResponse attribute)
(afkak.common.OffsetResponse attribute)
(afkak.common.ProduceResponse attribute)
F
failed_payloads (afkak.common.FailedPayloadsError attribute)
FailedPayloadsError
FetchRequest (class in afkak.common)
FetchResponse (class in afkak.common)
FetchSessionIdNotFound
G
GroupAuthorizationFailed
GroupIdNotFound
H
has_metadata_for_topic() (afkak.KafkaClient method)
highwaterMark (afkak.common.FetchResponse attribute)
host (afkak.common.BrokerMetadata attribute)
(afkak.common.ConsumerMetadataResponse attribute)
I
IllegalGeneration
IllegalSaslState
InconsistentGroupProtocol
InvalidCommitOffsetSize
InvalidConfig
InvalidConsumerGroupError
InvalidFetchRequestError
InvalidFetchSessionEpoch
InvalidGroupId
InvalidMessageError (in module afkak.common)
InvalidPartitions
InvalidPrincipalType
InvalidProducerEpoch
InvalidProducerIdMapping
InvalidReplicaAssignment
InvalidReplicationFactor
InvalidRequest
InvalidRequiredAcks
InvalidSessionTimeout
InvalidTimestamp
InvalidTopic
InvalidTransactionTimeout
InvalidTxnState
isr (afkak.common.PartitionMetadata attribute)
K
KafkaClient (class in afkak)
KafkaError
KafkaStorageError
KafkaUnavailableError
key (afkak.common.SendRequest attribute)
L
last_committed_offset (afkak.Consumer attribute)
last_processed_offset (afkak.Consumer attribute)
leader (afkak.common.PartitionMetadata attribute)
LeaderNotAvailableError
LeaderUnavailableError
ListenerNotFound
load_consumer_metadata_for_group() (afkak.KafkaClient method)
load_coordinator_for_group() (afkak.KafkaClient method)
load_metadata_for_topics() (afkak.KafkaClient method)
LogDirNotFound
M
max_bytes (afkak.common.FetchRequest attribute)
max_offsets (afkak.common.OffsetRequest attribute)
message (afkak.common.BrokerNotAvailableError attribute)
(afkak.common.BrokerResponseError attribute)
(afkak.common.ClusterAuthorizationFailed attribute)
(afkak.common.ConcurrentTransactions attribute)
(afkak.common.CoordinatorLoadInProgress attribute)
(afkak.common.CoordinatorNotAvailable attribute)
(afkak.common.CorruptMessage attribute)
(afkak.common.DelegationTokenAuthDisabled attribute)
(afkak.common.DelegationTokenAuthorizationFailed attribute)
(afkak.common.DelegationTokenExpired attribute)
(afkak.common.DelegationTokenNotFound attribute)
(afkak.common.DelegationTokenOwnerMismatch attribute)
(afkak.common.DelegationTokenRequestNotAllowed attribute)
(afkak.common.DuplicateSequenceNumber attribute)
(afkak.common.FetchSessionIdNotFound attribute)
(afkak.common.GroupAuthorizationFailed attribute)
(afkak.common.GroupIdNotFound attribute)
(afkak.common.IllegalGeneration attribute)
(afkak.common.IllegalSaslState attribute)
(afkak.common.InconsistentGroupProtocol attribute)
(afkak.common.InvalidCommitOffsetSize attribute)
(afkak.common.InvalidConfig attribute)
(afkak.common.InvalidFetchRequestError attribute)
(afkak.common.InvalidFetchSessionEpoch attribute)
(afkak.common.InvalidGroupId attribute)
(afkak.common.InvalidPartitions attribute)
(afkak.common.InvalidPrincipalType attribute)
(afkak.common.InvalidProducerEpoch attribute)
(afkak.common.InvalidProducerIdMapping attribute)
(afkak.common.InvalidReplicaAssignment attribute)
(afkak.common.InvalidReplicationFactor attribute)
(afkak.common.InvalidRequest attribute)
(afkak.common.InvalidRequiredAcks attribute)
(afkak.common.InvalidSessionTimeout attribute)
(afkak.common.InvalidTimestamp attribute)
(afkak.common.InvalidTopic attribute)
(afkak.common.InvalidTransactionTimeout attribute)
(afkak.common.InvalidTxnState attribute)
(afkak.common.KafkaStorageError attribute)
(afkak.common.LeaderNotAvailableError attribute)
(afkak.common.ListenerNotFound attribute)
(afkak.common.LogDirNotFound attribute)
(afkak.common.MessageSizeTooLargeError attribute)
(afkak.common.NetworkException attribute)
(afkak.common.NonEmptyGroup attribute)
(afkak.common.NotController attribute)
(afkak.common.NotCoordinator attribute)
(afkak.common.NotEnoughReplicas attribute)
(afkak.common.NotEnoughReplicasAfterAppend attribute)
(afkak.common.NotLeaderForPartitionError attribute)
(afkak.common.OffsetAndMessage attribute)
(afkak.common.OffsetMetadataTooLargeError attribute)
(afkak.common.OffsetOutOfRangeError attribute)
(afkak.common.OperationNotAttempted attribute)
(afkak.common.OutOfOrderSequenceNumber attribute)
(afkak.common.PolicyViolation attribute)
(afkak.common.ReassignmentInProgress attribute)
(afkak.common.RebalanceInProgress attribute)
(afkak.common.RecordListTooLarge attribute)
(afkak.common.ReplicaNotAvailableError attribute)
(afkak.common.RequestTimedOutError attribute)
(afkak.common.SaslAuthenticationFailed attribute)
(afkak.common.SecurityDisabled attribute)
(afkak.common.SourcedMessage attribute)
(afkak.common.StaleControllerEpochError attribute)
(afkak.common.TopicAlreadyExists attribute)
(afkak.common.TopicAuthorizationFailed attribute)
(afkak.common.TransactionCoordinatorFenced attribute)
(afkak.common.TransactionalIdAuthorizationFailed attribute)
(afkak.common.UnknownError attribute)
(afkak.common.UnknownMemberId attribute)
(afkak.common.UnknownProducerId attribute)
(afkak.common.UnknownTopicOrPartitionError attribute)
(afkak.common.UnsupportedForMessageFormat attribute)
(afkak.common.UnsupportedSaslMechanism attribute)
(afkak.common.UnsupportedVersion attribute)
Message (class in afkak.common)
messages (afkak.common.FetchResponse attribute)
(afkak.common.ProduceRequest attribute)
(afkak.common.SendRequest attribute)
MessageSizeTooLargeError
metadata (afkak.common.OffsetCommitRequest attribute)
(afkak.common.OffsetFetchResponse attribute)
metadata_error_for_topic() (afkak.KafkaClient method)
N
NetworkException
node_id (afkak.common.BrokerMetadata attribute)
(afkak.common.ConsumerMetadataResponse attribute)
NonEmptyGroup
NoResponseError
NotController
NotCoordinator
NotCoordinatorForConsumerError (in module afkak.common)
NotEnoughReplicas
NotEnoughReplicasAfterAppend
NotLeaderForPartitionError
O
offset (afkak.common.FetchRequest attribute)
(afkak.common.OffsetAndMessage attribute)
(afkak.common.OffsetCommitRequest attribute)
(afkak.common.OffsetFetchResponse attribute)
(afkak.common.ProduceResponse attribute)
(afkak.common.SourcedMessage attribute)
OffsetAndMessage (class in afkak.common)
OffsetCommitRequest (class in afkak.common)
OffsetCommitResponse (class in afkak.common)
OffsetFetchRequest (class in afkak.common)
OffsetFetchResponse (class in afkak.common)
OffsetMetadataTooLargeError
OffsetOutOfRangeError
OffsetRequest (class in afkak.common)
OffsetResponse (class in afkak.common)
offsets (afkak.common.OffsetResponse attribute)
OffsetsLoadInProgressError (in module afkak.common)
OperationInProgress
OperationNotAttempted
OutOfOrderSequenceNumber
P
partition (afkak.common.FetchRequest attribute)
(afkak.common.FetchResponse attribute)
(afkak.common.OffsetCommitRequest attribute)
(afkak.common.OffsetCommitResponse attribute)
(afkak.common.OffsetFetchRequest attribute)
(afkak.common.OffsetFetchResponse attribute)
(afkak.common.OffsetRequest attribute)
(afkak.common.OffsetResponse attribute)
(afkak.common.PartitionMetadata attribute)
(afkak.common.ProduceRequest attribute)
(afkak.common.ProduceResponse attribute)
(afkak.common.SourcedMessage attribute)
(afkak.common.TopicAndPartition attribute)
partition_error_code (afkak.common.PartitionMetadata attribute)
partition_fully_replicated() (afkak.KafkaClient method)
partition_metadata (afkak.common.TopicMetadata attribute)
PartitionMetadata (class in afkak.common)
PartitionUnavailableError
PolicyViolation
port (afkak.common.BrokerMetadata attribute)
(afkak.common.ConsumerMetadataResponse attribute)
Producer (class in afkak)
ProduceRequest (class in afkak.common)
ProduceResponse (class in afkak.common)
ProtocolError
R
raise_for_errno() (afkak.common.BrokerResponseError class method)
ReassignmentInProgress
RebalanceInProgress
RecordListTooLarge
ReplicaNotAvailableError
replicas (afkak.common.PartitionMetadata attribute)
RequestTimedOutError
reset_all_metadata() (afkak.KafkaClient method)
reset_consumer_group_metadata() (afkak.KafkaClient method)
reset_topic_metadata() (afkak.KafkaClient method)
responses (afkak.common.FailedPayloadsError attribute)
RestartError
RestopError
retriable (afkak.common.BrokerResponseError attribute)
(afkak.common.RetriableBrokerResponseError attribute)
RetriableBrokerResponseError
S
SaslAuthenticationFailed
SecurityDisabled
send_fetch_request() (afkak.KafkaClient method)
send_messages() (afkak.Producer method)
send_offset_commit_request() (afkak.KafkaClient method)
send_offset_fetch_request() (afkak.KafkaClient method)
send_offset_request() (afkak.KafkaClient method)
send_produce_request() (afkak.KafkaClient method)
SendRequest (class in afkak.common)
shutdown() (afkak.Consumer method)
SourcedMessage (class in afkak.common)
StaleControllerEpochError
StaleLeaderEpochCodeError (in module afkak.common)
start() (afkak.Consumer method)
stop() (afkak.Consumer method)
(afkak.Producer method)
T
time (afkak.common.OffsetRequest attribute)
timestamp (afkak.common.OffsetCommitRequest attribute)
topic (afkak.common.FetchRequest attribute)
(afkak.common.FetchResponse attribute)
(afkak.common.OffsetCommitRequest attribute)
(afkak.common.OffsetCommitResponse attribute)
(afkak.common.OffsetFetchRequest attribute)
(afkak.common.OffsetFetchResponse attribute)
(afkak.common.OffsetRequest attribute)
(afkak.common.OffsetResponse attribute)
(afkak.common.PartitionMetadata attribute)
(afkak.common.ProduceRequest attribute)
(afkak.common.ProduceResponse attribute)
(afkak.common.SendRequest attribute)
(afkak.common.SourcedMessage attribute)
(afkak.common.TopicAndPartition attribute)
(afkak.common.TopicMetadata attribute)
topic_error_code (afkak.common.TopicMetadata attribute)
topic_fully_replicated() (afkak.KafkaClient method)
TopicAlreadyExists
TopicAndPartition (class in afkak.common)
TopicAuthorizationFailed
TopicMetadata (class in afkak.common)
TransactionalIdAuthorizationFailed
TransactionCoordinatorFenced
U
UnknownError
UnknownMemberId
UnknownProducerId
UnknownTopicOrPartitionError
UnsupportedCodecError
UnsupportedForMessageFormat
UnsupportedSaslMechanism
UnsupportedVersion
update_cluster_hosts() (afkak.KafkaClient method)
Afkak
Navigation
API Documentation
Related Topics
Documentation overview
Quick search