RdKafka\KafkaConsumer::queryWatermarkOffsets

(No version information available, might only be in Git)

RdKafka\KafkaConsumer::queryWatermarkOffsets — Query offsets for a topic / partition

Description

public RdKafka\KafkaConsumer::queryWatermarkOffsets ( string $topic , integer $partition , integer &$low , integer &$high , integer $timeout_ms ) : void

Query broker for low (oldest/beginning) or high (newest/end) offsets for a partition

Parameters

topic (string): The topic name.
partition (integer): The partition.
&low (integer): The oldest/beginning offset for the partition
&high (integer): The newest/end offset for the partition.
timeout_ms (integer): Timeout in millisecounds for this operation.

Return Values

Returns no value.