pub struct ProduceRequestBuilder { /* private fields */ }
Expand description
Builder for ProduceRequest
.
Implementations§
source§impl ProduceRequestBuilder
impl ProduceRequestBuilder
sourcepub fn transactional_id(&mut self, value: Option<TransactionalId>) -> &mut Self
pub fn transactional_id(&mut self, value: Option<TransactionalId>) -> &mut Self
The transactional ID, or null if the producer is not transactional.
Supported API versions: 3-10
sourcepub fn acks(&mut self, value: i16) -> &mut Self
pub fn acks(&mut self, value: i16) -> &mut Self
The number of acknowledgments the producer requires the leader to have received before considering a request complete. Allowed values: 0 for no acknowledgments, 1 for only the leader and -1 for the full ISR.
Supported API versions: 0-10
sourcepub fn timeout_ms(&mut self, value: i32) -> &mut Self
pub fn timeout_ms(&mut self, value: i32) -> &mut Self
The timeout to await a response in milliseconds.
Supported API versions: 0-10
sourcepub fn topic_data(
&mut self,
value: IndexMap<TopicName, TopicProduceData>
) -> &mut Self
pub fn topic_data( &mut self, value: IndexMap<TopicName, TopicProduceData> ) -> &mut Self
Each topic to produce to.
Supported API versions: 0-10
sourcepub fn unknown_tagged_fields(
&mut self,
value: BTreeMap<i32, Bytes>
) -> &mut Self
pub fn unknown_tagged_fields( &mut self, value: BTreeMap<i32, Bytes> ) -> &mut Self
Other tagged fields
sourcepub fn build(&self) -> Result<ProduceRequest, ProduceRequestBuilderError>
pub fn build(&self) -> Result<ProduceRequest, ProduceRequestBuilderError>
Trait Implementations§
source§impl Clone for ProduceRequestBuilder
impl Clone for ProduceRequestBuilder
source§fn clone(&self) -> ProduceRequestBuilder
fn clone(&self) -> ProduceRequestBuilder
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreAuto Trait Implementations§
impl RefUnwindSafe for ProduceRequestBuilder
impl Send for ProduceRequestBuilder
impl Sync for ProduceRequestBuilder
impl Unpin for ProduceRequestBuilder
impl UnwindSafe for ProduceRequestBuilder
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more