Struct Murmur3HashHasher 

pub struct Murmur3HashHasher;

Pick the partition by hashing the message’s UTF-8-encoded partition key with murmur3_32_hash (Apache Pulsar Murmur3_32Hash, seed 0), then hash % partitions. Falls back to round-robin via OutgoingMessage::key being None or empty.

Wire-compatible with Java’s HashingScheme.Murmur3_32Hash so Java, C++, Go, and magnetar producers route the same key to the same partition.

Trait Implementations

impl Clone for Murmur3HashHasher

fn clone(&self) -> Murmur3HashHasher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Murmur3HashHasher

impl Debug for Murmur3HashHasher

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

Formats the value using the given formatter.

impl Default for Murmur3HashHasher

fn default() -> Murmur3HashHasher

Returns the “default value” for a type.

impl MessageRouter for Murmur3HashHasher

fn route(&self, msg: &OutgoingMessage, partitions: usize) -> usize

Pick a partition index in [0, partitions) for msg.