Enum Retry 

#[non_exhaustive]
pub enum Retry {
    Topic(String),
    SeekBack,
    Drop,
}

What nack(true) does on this subscription (see KafkaTopic::retry).

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Topic(String)

Republish the message to this topic (stamping RETRY_COUNT_HEADER), then settle the original offset. Republish-first ordering makes a crash between the two steps a duplicate, never a loss.

SeekBack

Seek the partition back to the message’s offset and re-consume it in place. Redelivery is immediate, but everything after the offset on that partition replays too (at-least-once duplicates), and the delivery count only survives within the session.

Drop

Treat nack(true) like the drop path (dead-letter when configured, settle otherwise).

Trait Implementations

impl Clone for Retry

fn clone(&self) -> Retry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Retry

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

Formats the value using the given formatter.

impl Eq for Retry

impl PartialEq for Retry

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Retry