Enum kafka::client::RequiredAcks

pub enum RequiredAcks {
    None,
    One,
    All,
}

Possible choices on acknowledgement requirements when producing/sending messages to Kafka. See KafkaClient::produce_messages.

Variants

None

Indicates to the receiving Kafka broker not to acknowlegde messages sent to it at all. Sending messages with this acknowledgement requirement translates into a fire-and-forget scenario which - of course - is very fast but not reliable.

One

Requires the receiving Kafka broker to wait until the sent messages are written to local disk. Such messages can be regarded as acknowledged by one broker in the cluster.

All

Requires the sent messages to be acknowledged by all in-sync replicas of the targeted topic partitions.

Trait Implementations

impl Debug for RequiredAcks

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Copy for RequiredAcks

impl Clone for RequiredAcks

fn clone(&self) -> RequiredAcks

Returns a copy of the value.

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

Performs copy-assignment from source.