ErrAllBrokersDown Local: All broker connections are down.

ErrApplication Local: Application generated error.

ErrAssignPartitions Local: Assign partitions.

ErrAuthentication Local: Authentication failure.

ErrBadCompression Local: Invalid compressed data.

ErrBadMsg Local: Bad message format.

ErrBrokerNotAvailable Broker: Broker not available.

ErrClusterAuthorizationFailed Broker: Cluster authorization failed.

ErrConcurrentTransactions Broker: Producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing.

ErrConflict Local: Conflicting use.

ErrCoordinatorLoadInProgress Broker: Coordinator load in progress.

ErrCoordinatorNotAvailable Broker: Coordinator not available.

ErrCritSysResource Local: Critical system resource failure.

ErrDelegationTokenAuthDisabled Broker: Delegation Token feature is not enabled.

ErrDelegationTokenAuthorizationFailed Broker: Delegation Token authorization failed.

ErrDelegationTokenExpired Broker: Delegation Token is expired.

ErrDelegationTokenNotFound Broker: Delegation Token is not found on server.

ErrDelegationTokenOwnerMismatch Broker: Specified Principal is not valid Owner/Renewer.

ErrDelegationTokenRequestNotAllowed Broker: Delegation Token requests are not allowed on this connection.

ErrDestroy Local: Broker handle destroyed.

ErrDuplicateSequenceNumber Broker: Broker received a duplicate sequence number.

ErrExistingSubscription Local: Existing subscription.

ErrFail Local: Communication failure with broker.

ErrFatal Local: Fatal error.

ErrFenced Local: This instance has been fenced by a newer instance.

ErrFencedInstanceID Broker: Static consumer fenced by other consumer with same group.instance.id.

ErrFencedLeaderEpoch Broker: Leader epoch is older than broker epoch.

ErrFetchSessionIDNotFound Broker: The fetch session ID was not found.

ErrFs Local: File or filesystem error.

ErrGaplessGuarantee Local: Gap-less ordering would not be guaranteed if proceeding.

ErrGroupAuthorizationFailed Broker: Group authorization failed.

ErrGroupIDNotFound Broker: The group id does not exist.

ErrGroupMaxSizeReached Broker: Consumer group has reached maximum size.

ErrIllegalGeneration Broker: Specified group generation id is not valid.

ErrIllegalSaslState Broker: Request not valid in current SASL state.

ErrInconsistent Local: Inconsistent state.

ErrInconsistentGroupProtocol Broker: Inconsistent group protocol.

ErrInProgress Local: Operation in progress.

ErrIntr Local: Operation interrupted.

ErrInvalidArg Local: Invalid argument or configuration.

ErrInvalidCommitOffsetSize Broker: Commit offset data size is not valid.

ErrInvalidConfig Broker: Configuration is invalid.

ErrInvalidFetchSessionEpoch Broker: The fetch session epoch is invalid.

ErrInvalidGroupID Broker: Invalid group.id.

ErrInvalidMsg Broker: Invalid message.

ErrInvalidMsgSize Broker: Invalid message size.

ErrInvalidPartitions Broker: Invalid number of partitions.

ErrInvalidPrincipalType Broker: Supplied principalType is not supported.

ErrInvalidProducerEpoch Broker: Producer attempted an operation with an old epoch.

ErrInvalidProducerIDMapping Broker: Producer attempted to use a producer id which is not currently assigned to its transactional id.

ErrInvalidReplicaAssignment Broker: Invalid replica assignment.

ErrInvalidReplicationFactor Broker: Invalid replication factor.

ErrInvalidRequest Broker: Invalid request.

ErrInvalidRequiredAcks Broker: Invalid required acks value.

ErrInvalidSessionTimeout Broker: Invalid session timeout.

ErrInvalidTimestamp Broker: Invalid timestamp.

ErrInvalidTransactionTimeout Broker: Transaction timeout is larger than the maximum value allowed by the broker's max.transaction.timeout.ms.

ErrInvalidTxnState Broker: Producer attempted a transactional operation in an invalid state.

ErrInvalidType Local: Invalid type.

ErrIsrInsuff Local: ISR count insufficient.

ErrKafkaStorageError Broker: Disk error when trying to access log file on disk.

ErrKeyDeserialization Local: Key deserialization error.

ErrKeySerialization Local: Key serialization error.

ErrLeaderNotAvailable Broker: Leader not available.

ErrListenerNotFound Broker: No matching listener.

ErrLogDirNotFound Broker: The user-specified log directory is not found in the broker config.

ErrMaxPollExceeded Local: Maximum application poll interval (max.poll.interval.ms) exceeded.

ErrMemberIDRequired Broker: Group member needs a valid member ID.

ErrMsgSizeTooLarge Broker: Message size too large.

ErrMsgTimedOut Local: Message timed out.

ErrNetworkException Broker: Broker disconnected before response received.

ErrNodeUpdate Local: Broker node update.

ErrNoent Local: No such entry.

ErrNoError Success.

ErrNonEmptyGroup Broker: The group is not empty.

ErrNoOffset Local: No offset stored.

ErrNotConfigured Local: Functionality not configured.

ErrNotController Broker: Not controller for cluster.

ErrNotCoordinator Broker: Not coordinator.

ErrNotEnoughReplicas Broker: Not enough in-sync replicas.

ErrNotEnoughReplicasAfterAppend Broker: Message(s) written to insufficient number of in-sync replicas.

ErrNotImplemented Local: Not implemented.

ErrNotLeaderForPartition Broker: Not leader for partition.

ErrOffsetMetadataTooLarge Broker: Offset metadata string too large.

ErrOffsetNotAvailable Broker: Leader high watermark is not caught up.

ErrOffsetOutOfRange Broker: Offset out of range.

ErrOperationNotAttempted Broker: Operation not attempted.

ErrOutdated Local: Outdated.

ErrOutOfOrderSequenceNumber Broker: Broker received an out of order sequence number.

ErrPartial Local: Partial response.

ErrPartitionEOF Broker: No more messages.

ErrPolicyViolation Broker: Policy violation.

ErrPreferredLeaderNotAvailable Broker: Preferred leader was not available.

ErrPrevInProgress Local: Previous operation in progress.

ErrPurgeInflight Local: Purged in flight.

ErrPurgeQueue Local: Purged in queue.

ErrQueueFull Local: Queue full.

ErrReadOnly Local: Read-only object.

ErrReassignmentInProgress Broker: Partition reassignment is in progress.

ErrRebalanceInProgress Broker: Group rebalance in progress.

ErrRecordListTooLarge Broker: Message batch larger than configured server segment size.

ErrReplicaNotAvailable Broker: Replica not available.

ErrRequestTimedOut Broker: Request timed out.

ErrResolve Local: Host resolution failure.

ErrRetry Local: Retry operation.

ErrRevokePartitions Local: Revoke partitions.

ErrSaslAuthenticationFailed Broker: SASL Authentication failed.

ErrSecurityDisabled Broker: Security features are disabled.

ErrSsl Local: SSL error.

ErrStaleBrokerEpoch Broker: Broker epoch has changed.

ErrStaleCtrlEpoch Broker: StaleControllerEpochCode.

ErrState Local: Erroneous state.

ErrTimedOut Local: Timed out.

ErrTimedOutQueue Local: Timed out in queue.

ErrTopicAlreadyExists Broker: Topic already exists.

ErrTopicAuthorizationFailed Broker: Topic authorization failed.

ErrTopicDeletionDisabled Broker: Topic deletion is disabled.

ErrTopicException Broker: Invalid topic.

ErrTransactionalIDAuthorizationFailed Broker: Transactional Id authorization failed.

ErrTransactionCoordinatorFenced Broker: Indicates that the transaction coordinator sending a WriteTxnMarker is no longer the current coordinator for a given producer.

ErrTransport Local: Broker transport failure.

ErrUnderflow Local: Read underflow.

ErrUnknown Unknown broker error.

ErrUnknownBroker Local: Unknown broker.

ErrUnknownGroup Local: Unknown group.

ErrUnknownLeaderEpoch Broker: Leader epoch is newer than broker epoch.

ErrUnknownMemberID Broker: Unknown member.

ErrUnknownPartition Local: Unknown partition.

ErrUnknownProducerID Broker: Unknown Producer Id.

ErrUnknownProtocol Local: Unknown protocol.

ErrUnknownTopic Local: Unknown topic.

ErrUnknownTopicOrPart Broker: Unknown topic or partition.

ErrUnsupportedCompressionType Broker: Unsupported compression type.

ErrUnsupportedFeature Local: Required feature not supported by broker.

ErrUnsupportedForMessageFormat Broker: Message format on broker does not support request.

ErrUnsupportedSaslMechanism Broker: Unsupported SASL mechanism.

ErrUnsupportedVersion Broker: API version not supported.

ErrValueDeserialization Local: Value deserialization error.

ErrValueSerialization Local: Value serialization error.

ErrWaitCache Local: Awaiting cache update.

ErrWaitCoord Local: Waiting for coordinator.

interface & struct.

interface & struct.

interface & struct.

interface & struct.

interface & struct.

interface & struct.

interface & struct.

interface & struct.

func.

interface & struct.

interface & struct.

func.

interface & struct.

interface & struct.

interface & struct.

interface & struct.

interface & struct.