queryWatermarkOffsets

Description

public function queryWatermarkOffsets(string $topic, int $partition, int &$low, int &$high, int $timeoutMs): void {}

Query broker for low (oldest) and high (newest) offsets for a partition

Example

$low = 0;
$high = 0;

$conf = SimpleKafkaClient\Configuration();
$conf->set('metadata.broker.list', 'kafka:9092');
$producer = new SimpleKafkaClient\Producer($conf);
$topicPartition = new TopicPartition('test-topic', 0, strtotime("-1 week"));
$producer->queryWatermarkOffsets('test-topic', 0, int &$low, int &$high, 10000);