Struct NoCustomPartitioner

pub struct NoCustomPartitioner {}

Placeholder used when no custom partitioner is needed.

Trait Implementations

impl Clone for NoCustomPartitioner

fn clone(&self) -> NoCustomPartitioner

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Partitioner for NoCustomPartitioner

fn partition( &self, _topic_name: &str, _key: Option<&[u8]>, _partition_cnt: i32, _is_paritition_available: impl Fn(i32) -> bool, ) -> i32

Return partition to use for topic_name. topic_name is the name of a topic to which a message is being produced. partition_cnt is the number of partitions for this topic. key is an optional key of the message. is_partition_available is a function that can be called to check if a partition has an active leader broker.