Struct Builder

pub struct Builder<P = DefaultPartitioner> { /* private fields */ }

A Kafka Producer builder easing the process of setting up various configuration settings.

Implementations

impl Builder

pub fn with_compression(self, compression: Compression) -> Self

Sets the compression algorithm to use when sending out data.

See KafkaClient::set_compression.

pub fn with_ack_timeout(self, timeout: Duration) -> Self

Sets the maximum time the kafka brokers can await the receipt of required acknowledgements (which is specified through Builder::with_required_acks.) Note that Kafka explicitly documents this not to be a hard limit.

pub fn with_connection_idle_timeout(self, timeout: Duration) -> Self

Specifies the timeout for idle connections. See KafkaClient::set_connection_idle_timeout.

pub fn with_required_acks(self, acks: RequiredAcks) -> Self

Sets how many acknowledgements the kafka brokers should receive before responding to sent messages.

See RequiredAcks.

pub fn with_client_id(self, client_id: String) -> Self

Specifies a client_id to be sent along every request to Kafka brokers. See KafkaClient::set_client_id.

impl<P> Builder<P>

pub fn with_partitioner<Q: Partitioner>(self, partitioner: Q) -> Builder<Q>

Sets the partitioner to dispatch when sending messages without an explicit partition assignment.

pub fn create(self) -> Result<Producer<P>>

Finally creates/builds a new producer based on the so far supplied settings.