errors

Documentation

Index

• type KafkaError

Types

type KafkaError

type KafkaError int16

const (
	UnknownServerError KafkaError = iota - 1
	None
	OffsetOutOfRange
	CorruptMessage
	UnknownTopicOrPartition
	InvalidFetchSize
	LeaderNotAvailable
	NotLeaderOrFollower
	RequestTimedOut
	BrokerNotAvailable
	ReplicaNotAvailable
	MessageTooLarge
	StaleControllerEpoch
	OffsetMetadataTooLarge
	NetworkException
	CoordinatorLoadInProgress
	CoordinatorNotAvailable
	NotCoordinator
	InvalidTopicException
	RecordListTooLarge
	NotEnoughReplicas
	NotEnoughReplicasAfterAppend
	InvalidRequiredAcks
	IllegalGeneration
	InconsistentGroupProtocol
	InvalidGroupID
	UnknownMemberID
	InvalidSessionTimeout
	RebalanceInProgress
	InvalidCommitOffsetSize
	TopicAuthorizationFailed
	GroupAuthorizationFailed
	ClusterAuthorizationFailed
	InvalidTimestamp
	UnsupportedSASLMechanism
	IllegalSQSLState
	UnsupportedVersion
	TopicAlreadyExists
	InvalidPartitions
	InvalidReplicationFactor
	InvalidReplicaAssignment
	InvalidConfig
	NotController
	InvalidRequest
	UnsupportedForMessageFormat
	PolicyViolation
	OutOfOrderSequenceNumber
	DuplicateSequenceNumber
	InvalidProducerEpoch
	InvalidTXNState
	InvalidProducerIDMapping
	InvalidTransactionTimeout
	ConcurrentTransactions
	TransactionCoordinatorFenced
	TransactionIDAuthorizationFailed
	SecurityDisabled
	OperationNotAttempted
	KafkaStorageError
	LogDirNotFound
	SASLAuthenticationFailed
	UnknownProducerID
	ReassignmentInProgress
	DelegationTokenAuthDisabled
	DelegationTokenNotFound
	DelegationTokenOwnerMismatch
	DelegationTokenRequestNotAllow
	DelegationTokenAuthorizationFailed
	DelegationTokenExpired
	InvalidPrincipalType
	NonEmptyGroup
	GroupIDNotFound
	FetchSessionIDNotFound
	InvalidFetchSessionEpoch
	ListenerNotFound
	TopicDeletionDisabled
	FencedLeaderEpoch
	UnknownLeaderEpoch
	UnsupportedCompressionType
	StaleBrokerEpoch
	OffsetNotAvailable
	MemberIDRequired
	PreferredLeaderNotAvailable
	GroupMaxSizeReached
	FencedInstanceID
	EligibleLeadersNotAvailable
	ElectionNotNeeded
	NoReassignmentInProgress
	GroupSubscribedToTopic
	InvalidRecord
	UnstableOffsetCommit
)