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

RdKafka\KafkaConsumer::queryWatermarkOffsetsQuery offsets for a topic / partition


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


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.