Enum BrokerErrorKind 

pub enum BrokerErrorKind {
    Unknown,
    OffsetOutOfRange,
    UnknownTopicOrPartition,
    LeaderNotAvailable,
    NotLeaderOrFollower,
    RequestTimedOut,
    ReplicaNotAvailable,
    InvalidTopic,
    CoordinatorNotAvailable,
    CoordinatorLoadInProgress,
    NotCoordinator,
    IllegalGeneration,
    InconsistentGroupProtocol,
    UnknownMemberId,
    InvalidSessionTimeout,
    RebalanceInProgress,
    TopicAuthorizationFailed,
    ClusterAuthorizationFailed,
    TopicAlreadyExists,
    InvalidPartitions,
    InvalidReplicationFactor,
    InvalidReplicaAssignment,
    InvalidConfig,
    NotController,
    InvalidRequest,
    OutOfOrderSequenceNumber,
    DuplicateSequenceNumber,
    InvalidProducerEpoch,
    ProducerFenced,
    ConcurrentTransactions,
    GroupIdNotFound,
    NonEmptyGroup,
    GroupSubscribedToTopic,
    FencedInstanceId,
    FencedMemberEpoch,
    StaleMemberEpoch,
    FencedLeaderEpoch,
    UnknownLeaderEpoch,
    InvalidFetchSessionEpoch,
    ShareSessionNotFound,
    InvalidShareSessionEpoch,
    FencedStateEpoch,
    InvalidRecordState,
    ShareSessionLimitReached,
    EligibleLeadersNotAvailable,
    ElectionNotNeeded,
    NoReassignmentInProgress,
}

Kafka broker error categories used by kafrust retry and diagnostics code.

Variants

Unknown

An error code that kafrust does not classify yet.

OffsetOutOfRange

Kafka reported that the requested fetch offset is outside the retained log.

UnknownTopicOrPartition

Kafka reported an unknown topic or partition.

LeaderNotAvailable

Kafka reported that a partition leader is not currently available.

NotLeaderOrFollower

Kafka reported that the target broker is not the leader or follower.

RequestTimedOut

Kafka reported that the broker-side request timed out.

ReplicaNotAvailable

Kafka reported that a replica is unavailable.

InvalidTopic

Kafka rejected an invalid topic name or definition.

CoordinatorNotAvailable

Kafka reported that the coordinator is unavailable.

CoordinatorLoadInProgress

Kafka reported that the coordinator is still loading its state.

NotCoordinator

Kafka reported that the request was sent to the wrong coordinator.

IllegalGeneration

Kafka reported an invalid consumer group generation.

InconsistentGroupProtocol

Kafka reported inconsistent group protocol metadata.

UnknownMemberId

Kafka reported an unknown consumer group member ID.

InvalidSessionTimeout

Kafka rejected the configured session timeout.

RebalanceInProgress

Kafka reported that a group rebalance is in progress.

TopicAuthorizationFailed

Kafka denied access to a topic.

ClusterAuthorizationFailed

Kafka denied access to the cluster operation.

TopicAlreadyExists

Kafka reported that the topic already exists.

InvalidPartitions

Kafka rejected the requested partition count.

InvalidReplicationFactor

Kafka rejected the requested replication factor.

InvalidReplicaAssignment

Kafka rejected an explicit replica assignment.

InvalidConfig

Kafka rejected a topic or broker configuration.

NotController

Kafka reported that this broker is not the active controller.

InvalidRequest

Kafka rejected an invalid request.

OutOfOrderSequenceNumber

Kafka received a producer sequence larger than the expected sequence.

DuplicateSequenceNumber

Kafka recognized a retry of an already appended producer sequence.

InvalidProducerEpoch

Kafka rejected an operation from an older producer epoch.

ProducerFenced

Kafka fenced this producer with a newer producer instance.

ConcurrentTransactions

Kafka is still completing another transaction for this transactional ID.

GroupIdNotFound

Kafka reported that the requested consumer group does not exist.

NonEmptyGroup

Kafka refused to delete a group that still has active members.

GroupSubscribedToTopic

Kafka rejected offset deletion because the group still subscribes to the topic.

FencedInstanceId

Kafka fenced a static consumer because another member uses the same instance ID.

FencedMemberEpoch

Kafka fenced a consumer-group member epoch.

StaleMemberEpoch

Kafka reported a stale consumer-group member epoch.

FencedLeaderEpoch

Kafka rejected a fetch because the supplied leader epoch is fenced.

UnknownLeaderEpoch

Kafka could not identify the supplied leader epoch during a transition.

InvalidFetchSessionEpoch

Kafka rejected the current fetch session epoch and requires a new session.

ShareSessionNotFound

Kafka could not find the share session for this member.

InvalidShareSessionEpoch

Kafka rejected the current share session epoch.

FencedStateEpoch

Kafka fenced the share-group state epoch.

InvalidRecordState

Kafka rejected an acknowledgement because the record is no longer acquired.

ShareSessionLimitReached

Kafka could not create a share session because the broker limit was reached.

EligibleLeadersNotAvailable

Kafka found no eligible replica for the requested leader election.

ElectionNotNeeded

Kafka reported that the requested leader is already preferred.

NoReassignmentInProgress

Kafka reported that no partition reassignment is currently active.

Implementations

impl BrokerErrorKind

pub fn from_code(code: i16) -> Self

Classifies a Kafka protocol error code.

pub fn is_produce_retryable(self) -> bool

Returns whether this broker error is retryable for the current producer path.

Trait Implementations

impl Clone for BrokerErrorKind

fn clone(&self) -> BrokerErrorKind

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for BrokerErrorKind

impl Debug for BrokerErrorKind

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for BrokerErrorKind

impl PartialEq for BrokerErrorKind

fn eq(&self, other: &BrokerErrorKind) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for BrokerErrorKind