[−][src]Enum kafka::client::RequiredAcks
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 Clone for RequiredAcks
[src]
fn clone(&self) -> RequiredAcks
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for RequiredAcks
[src]
impl Debug for RequiredAcks
[src]
Auto Trait Implementations
impl Unpin for RequiredAcks
impl Sync for RequiredAcks
impl Send for RequiredAcks
impl UnwindSafe for RequiredAcks
impl RefUnwindSafe for RequiredAcks
Blanket Implementations
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> From<T> for T
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,