Enum RequiredAcks

pub enum RequiredAcks {
    None = 0,
    One = 1,
    All = -1,
}

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

Variants

None = 0

Indicates to the receiving Kafka broker not to acknowledge 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 = 1

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 = -1

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

Trait Implementations

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.

impl Debug for RequiredAcks

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Copy for RequiredAcks