Handle.getWatermarkOffsets

Get last known low (oldest/beginning) and high (newest/end) offsets for partition.

The low offset is updated periodically (if statistics.interval.ms is set) while the high offset is updated on each fetched message set from the broker.

If there is no cached offset (either low or high, or both) then OFFSET_INVALID will be returned for the respective offset.

Offsets are returned in \p *low and \p *high respectively.

ErrorCode.no_error on success or an error code on failure.

Note: Shall only be used with an active consumer instance.

class Handle
@nogc nothrow
getWatermarkOffsets
(
const(char)* topic
,,
ref long low
,
ref long high
)

Meta