#[non_exhaustive]pub struct AddPartitionsToTxnTransaction {
pub transactional_id: TransactionalId,
pub producer_id: ProducerId,
pub producer_epoch: i16,
pub verify_only: bool,
pub topics: Vec<AddPartitionsToTxnTopic>,
pub unknown_tagged_fields: BTreeMap<i32, Bytes>,
}
Expand description
Valid versions: 0-5
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. }
syntax; cannot be matched against without a wildcard ..
; and struct update syntax will not work.transactional_id: TransactionalId
The transactional id corresponding to the transaction.
Supported API versions: 4-5
producer_id: ProducerId
Current producer id in use by the transactional id.
Supported API versions: 4-5
producer_epoch: i16
Current epoch associated with the producer id.
Supported API versions: 4-5
verify_only: bool
Boolean to signify if we want to check if the partition is in the transaction rather than add it.
Supported API versions: 4-5
topics: Vec<AddPartitionsToTxnTopic>
The partitions to add to the transaction.
Supported API versions: 4-5
unknown_tagged_fields: BTreeMap<i32, Bytes>
Other tagged fields
Implementations§
Source§impl AddPartitionsToTxnTransaction
impl AddPartitionsToTxnTransaction
Sourcepub fn with_transactional_id(self, value: TransactionalId) -> Self
pub fn with_transactional_id(self, value: TransactionalId) -> Self
Sets transactional_id
to the passed value.
The transactional id corresponding to the transaction.
Supported API versions: 4-5
Sourcepub fn with_producer_id(self, value: ProducerId) -> Self
pub fn with_producer_id(self, value: ProducerId) -> Self
Sets producer_id
to the passed value.
Current producer id in use by the transactional id.
Supported API versions: 4-5
Sourcepub fn with_producer_epoch(self, value: i16) -> Self
pub fn with_producer_epoch(self, value: i16) -> Self
Sets producer_epoch
to the passed value.
Current epoch associated with the producer id.
Supported API versions: 4-5
Sourcepub fn with_verify_only(self, value: bool) -> Self
pub fn with_verify_only(self, value: bool) -> Self
Sets verify_only
to the passed value.
Boolean to signify if we want to check if the partition is in the transaction rather than add it.
Supported API versions: 4-5
Sourcepub fn with_topics(self, value: Vec<AddPartitionsToTxnTopic>) -> Self
pub fn with_topics(self, value: Vec<AddPartitionsToTxnTopic>) -> Self
Sets topics
to the passed value.
The partitions to add to the transaction.
Supported API versions: 4-5
Sourcepub fn with_unknown_tagged_fields(self, value: BTreeMap<i32, Bytes>) -> Self
pub fn with_unknown_tagged_fields(self, value: BTreeMap<i32, Bytes>) -> Self
Sets unknown_tagged_fields to the passed value.
Sourcepub fn with_unknown_tagged_field(self, key: i32, value: Bytes) -> Self
pub fn with_unknown_tagged_field(self, key: i32, value: Bytes) -> Self
Inserts an entry into unknown_tagged_fields.
Trait Implementations§
Source§impl Clone for AddPartitionsToTxnTransaction
impl Clone for AddPartitionsToTxnTransaction
Source§fn clone(&self) -> AddPartitionsToTxnTransaction
fn clone(&self) -> AddPartitionsToTxnTransaction
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Decodable for AddPartitionsToTxnTransaction
Available on crate feature broker
only.
impl Decodable for AddPartitionsToTxnTransaction
broker
only.Source§impl Encodable for AddPartitionsToTxnTransaction
Available on crate feature client
only.
impl Encodable for AddPartitionsToTxnTransaction
client
only.Source§impl Message for AddPartitionsToTxnTransaction
impl Message for AddPartitionsToTxnTransaction
Source§const VERSIONS: VersionRange
const VERSIONS: VersionRange
Source§const DEPRECATED_VERSIONS: Option<VersionRange> = None
const DEPRECATED_VERSIONS: Option<VersionRange> = None
Source§impl PartialEq for AddPartitionsToTxnTransaction
impl PartialEq for AddPartitionsToTxnTransaction
Source§fn eq(&self, other: &AddPartitionsToTxnTransaction) -> bool
fn eq(&self, other: &AddPartitionsToTxnTransaction) -> bool
self
and other
values to be equal, and is used by ==
.