Enum LaneKey 

#[non_exhaustive]
pub enum LaneKey {
    Partition,
    RecordKey,
}

What drives keyed worker lanes (workers(n, by_key)) for this subscription.

The runtime lanes deliveries by IncomingMessage::partition_key (deliveries sharing a lane key process in order on one lane); this choice picks what that key is for Kafka.

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.

Partition

The source partition (the default): lanes mirror Kafka’s own ordering unit, so everything a partition delivers (keyless included) processes in order on one lane.

RecordKey

The native record key: per-key ordering, finer than a partition, so messages of one partition may process concurrently when their keys differ. Keyless deliveries carry no lane key and rotate across lanes, losing their partition order.

Trait Implementations

impl Clone for LaneKey

fn clone(&self) -> LaneKey

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for LaneKey

impl Debug for LaneKey

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

Formats the value using the given formatter.

impl Default for LaneKey

fn default() -> LaneKey

Returns the “default value” for a type.

impl Eq for LaneKey

impl PartialEq for LaneKey

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for LaneKey