Struct kafka_protocol::messages::list_offsets_request::ListOffsetsRequest

#[non_exhaustive]
pub struct ListOffsetsRequest {
    pub replica_id: BrokerId,
    pub isolation_level: i8,
    pub topics: Vec<ListOffsetsTopic>,
    pub unknown_tagged_fields: BTreeMap<i32, Bytes>,
}

Valid versions: 0-8

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional 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-8

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-8

topics: Vec<ListOffsetsTopic>

Each topic in the request.

Supported API versions: 0-8

unknown_tagged_fields: BTreeMap<i32, Bytes>

Other tagged fields

Implementations

impl ListOffsetsRequest

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-8

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-8

pub fn with_topics(self, value: Vec<ListOffsetsTopic>) -> Self

Sets topics to the passed value.

Each topic in the request.

Supported API versions: 0-8

pub fn with_unknown_tagged_fields(self, value: BTreeMap<i32, Bytes>) -> Self

Sets unknown_tagged_fields to the passed value.

pub fn with_unknown_tagged_field(self, key: i32, value: Bytes) -> Self

Inserts an entry into unknown_tagged_fields.

Trait Implementations

impl Clone for ListOffsetsRequest

fn clone(&self) -> ListOffsetsRequest

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ListOffsetsRequest

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

Formats the value using the given formatter.

impl Decodable for ListOffsetsRequest

fn decode<B: ByteBuf>(buf: &mut B, version: i16) -> Result<Self>

Decode the message from the provided buffer and version.

impl Default for ListOffsetsRequest

fn default() -> Self

Returns the “default value” for a type.

impl Encodable for ListOffsetsRequest

fn encode<B: ByteBufMut>(&self, buf: &mut B, version: i16) -> Result<()>

Encode the message into the target buffer.

fn compute_size(&self, version: i16) -> Result<usize>

Compute the total size of the message when encoded.

impl From<ListOffsetsRequest> for RequestKind

fn from(value: ListOffsetsRequest) -> RequestKind

Converts to this type from the input type.

impl HeaderVersion for ListOffsetsRequest

fn header_version(version: i16) -> i16

Maps a header version to a given version for a particular API message.

impl Message for ListOffsetsRequest

const VERSIONS: VersionRange = _

The valid versions for this message.

const DEPRECATED_VERSIONS: Option<VersionRange> = _

The deprecated versions for this message.

impl PartialEq for ListOffsetsRequest

fn eq(&self, other: &ListOffsetsRequest) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Request for ListOffsetsRequest

const KEY: i16 = 2i16

The API key of this request.

type Response = ListOffsetsResponse

The response associated with this request.

impl StructuralPartialEq for ListOffsetsRequest