function RdKafkaCaster::extractMetadata

2 calls to RdKafkaCaster::extractMetadata()

RdKafkaCaster::castKafkaConsumer in vendor/symfony/var-dumper/Caster/RdKafkaCaster.php

RdKafkaCaster::castRdKafka in vendor/symfony/var-dumper/Caster/RdKafkaCaster.php

File

vendor/symfony/var-dumper/Caster/RdKafkaCaster.php, line 169

Class

RdKafkaCaster

Casts RdKafka related classes to array representation.

Namespace

Symfony\Component\VarDumper\Caster

Code

private static function extractMetadata(KafkaConsumer|\RdKafka $c) : array {
    $prefix = Caster::PREFIX_VIRTUAL;
    try {
        $m = $c->getMetadata(true, null, 500);
    } catch (RdKafkaException) {
        return [];
    }
    return [
        $prefix . 'orig_broker_id' => $m->getOrigBrokerId(),
        $prefix . 'orig_broker_name' => $m->getOrigBrokerName(),
        $prefix . 'brokers' => $m->getBrokers(),
        $prefix . 'topics' => $m->getTopics(),
    ];
}