Enum MessageRoutingMode 

pub enum MessageRoutingMode {
    KeyHashOrRoundRobin,
    RoundRobin,
    SinglePartition(u32),
}

How a PartitionedProducer picks the partition for an outgoing message.

Variants

KeyHashOrRoundRobin

Hash the message’s partition key via Java’s String.hashCode() (the HashingScheme.JavaStringHash default), then % partitions. Falls back to round-robin when no key is set or the key is empty. Wire-compatible with Java’s default routing: the same key on a Rust producer and a Java producer lands on the same partition.

RoundRobin

Always round-robin, ignoring any partition key.

SinglePartition(u32)

Always route to a single partition (single_partition_index). Useful for ordered streams that don’t need parallelism.

Trait Implementations

impl Clone for MessageRoutingMode

fn clone(&self) -> MessageRoutingMode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for MessageRoutingMode

impl Debug for MessageRoutingMode

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

Formats the value using the given formatter.

impl Default for MessageRoutingMode

fn default() -> MessageRoutingMode

Returns the “default value” for a type.

impl Eq for MessageRoutingMode

impl PartialEq for MessageRoutingMode

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for MessageRoutingMode