madsim_rdkafka::producer

Trait Partitioner

Source 
pub trait Partitioner: Send + Sync {
    // Required method
    fn partition(
        &self,
        topic_name: &str,
        key: Option<&[u8]>,
        partition_cnt: i32,
        is_partition_available: impl Fn(i32) -> bool,
    ) -> i32;
}
Expand description

Trait allowing to customize the partitioning of messages.

Required Methods§

Source

fn partition( &self, topic_name: &str, key: Option<&[u8]>, partition_cnt: i32, is_partition_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.

It may be called in any thread at any time, It may be called multiple times for the same message/key. MUST NOT block or execute for prolonged periods of time. MUST return a value between 0 and partition_cnt-1, or the special RD_KAFKA_PARTITION_UA value if partitioning could not be performed. See documentation for rd_kafka_topic_conf_set_partitioner_cb from librdkafka for more info.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§