getBrokers
public function getBrokers(): Metadata\Collection {}
Get metadata of all brokers
Will return a Metadata\Collection
of Metadata\Broker
$conf = new SimpleKafkaClient\Configuration();
$conf->set('auto.offset.reset', 'earliest');
$producer = new SimpleKafkaClient\Producer($conf);
$metadata = $producer->getMetadata(false, 10000);
echo $metadata->getBrokers()->current()->getHost() . PHP_EOL;
echo $metadata->getBrokers()->current()->getPort() . PHP_EOL;