getIsrs

Description

public function getIsrs(): Collection {}

Topic partition in-sync replicas reported by broker

Example

$conf = new SimpleKafkaClient\Configuration();
$conf->set('auto.offset.reset', 'earliest');
$producer = new SimpleKafkaClient\Producer($conf);
$metadata = $producer->getMetadata(false, 10000);
$isrs = $metadata->getTopics()->current()->getPartitions()->current()->getIsrs();
while ($isrs->valid()) {
    echo sprintf('Insync Replicas id: %d', $isrs->current()) . PHP_EOL;
    $isrs->next();
}