#[non_exhaustive]pub struct ListOffsetsRequest {
pub replica_id: BrokerId,
pub isolation_level: i8,
pub topics: Vec<ListOffsetsTopic>,
pub unknown_tagged_fields: BTreeMap<i32, Bytes>,
}
Expand description
Valid versions: 0-9
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.replica_id: BrokerId
The broker ID of the requester, or -1 if this request is being made by a normal consumer.
Supported API versions: 0-9
isolation_level: i8
This setting controls the visibility of transactional records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records visible. With READ_COMMITTED (isolation_level = 1), non-transactional and COMMITTED transactional records are visible. To be more concrete, READ_COMMITTED returns all data from offsets smaller than the current LSO (last stable offset), and enables the inclusion of the list of aborted transactions in the result, which allows consumers to discard ABORTED transactional records
Supported API versions: 2-9
topics: Vec<ListOffsetsTopic>
Each topic in the request.
Supported API versions: 0-9
unknown_tagged_fields: BTreeMap<i32, Bytes>
Other tagged fields
Implementations§
Source§impl ListOffsetsRequest
impl ListOffsetsRequest
Sourcepub fn with_replica_id(self, value: BrokerId) -> Self
pub fn with_replica_id(self, value: BrokerId) -> Self
Sets replica_id
to the passed value.
The broker ID of the requester, or -1 if this request is being made by a normal consumer.
Supported API versions: 0-9
Sourcepub fn with_isolation_level(self, value: i8) -> Self
pub fn with_isolation_level(self, value: i8) -> Self
Sets isolation_level
to the passed value.
This setting controls the visibility of transactional records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records visible. With READ_COMMITTED (isolation_level = 1), non-transactional and COMMITTED transactional records are visible. To be more concrete, READ_COMMITTED returns all data from offsets smaller than the current LSO (last stable offset), and enables the inclusion of the list of aborted transactions in the result, which allows consumers to discard ABORTED transactional records
Supported API versions: 2-9
Sourcepub fn with_topics(self, value: Vec<ListOffsetsTopic>) -> Self
pub fn with_topics(self, value: Vec<ListOffsetsTopic>) -> Self
Sets topics
to the passed value.
Each topic in the request.
Supported API versions: 0-9
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 ListOffsetsRequest
impl Clone for ListOffsetsRequest
Source§fn clone(&self) -> ListOffsetsRequest
fn clone(&self) -> ListOffsetsRequest
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Debug for ListOffsetsRequest
impl Debug for ListOffsetsRequest
Source§impl Decodable for ListOffsetsRequest
Available on crate feature broker
only.
impl Decodable for ListOffsetsRequest
broker
only.Source§impl Default for ListOffsetsRequest
impl Default for ListOffsetsRequest
Source§impl Encodable for ListOffsetsRequest
Available on crate feature client
only.
impl Encodable for ListOffsetsRequest
client
only.Source§impl From<ListOffsetsRequest> for RequestKind
Available on crate feature messages_enums
only.
impl From<ListOffsetsRequest> for RequestKind
messages_enums
only.Source§fn from(value: ListOffsetsRequest) -> RequestKind
fn from(value: ListOffsetsRequest) -> RequestKind
Source§impl HeaderVersion for ListOffsetsRequest
impl HeaderVersion for ListOffsetsRequest
Source§fn header_version(version: i16) -> i16
fn header_version(version: i16) -> i16
Source§impl Message for ListOffsetsRequest
impl Message for ListOffsetsRequest
Source§const VERSIONS: VersionRange
const VERSIONS: VersionRange
Source§const DEPRECATED_VERSIONS: Option<VersionRange>
const DEPRECATED_VERSIONS: Option<VersionRange>
Source§impl PartialEq for ListOffsetsRequest
impl PartialEq for ListOffsetsRequest
Source§impl Request for ListOffsetsRequest
Available on crate features client
and broker
only.
impl Request for ListOffsetsRequest
client
and broker
only.