rustfs-kafka 1.2.0

Rust client for Apache Kafka
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

//! Partitioning strategies for message distribution across topic partitions.
//!
//! Provides the [`Partitioner`] trait and several built-in implementations:
//!
//! - [`DefaultPartitioner`] — hash-based key partitioning (default)
//! - [`RoundRobinPartitioner`] — round-robin for keyless messages
//! - [`StickyPartitioner`] — sticks to one partition per batch
//! - [`UniformPartitioner`] — random uniform distribution

mod default;
mod round_robin;
mod sticky;
mod uniform;

pub use default::DefaultPartitioner;
pub use default::Partitions;
pub use default::Topics;
pub use round_robin::RoundRobinPartitioner;
pub use sticky::StickyPartitioner;
pub use uniform::UniformPartitioner;

use crate::client;

// --------------------------------------------------------------------

/// A partitioner is given a chance to choose/redefine a partition for
/// a message to be sent to Kafka.  See also
/// `Record#with_partition`.
///
/// Implementations can be stateful.
pub trait Partitioner: Send + Sync {
    /// Supposed to inspect the given message and if desired re-assign
    /// the message's target partition.
    fn partition(&mut self, topics: Topics<'_>, msg: &mut client::ProduceMessage<'_, '_>);
}