<form method="POST">
    <h3>Editing: RdKafkaCaster.php</h3>
    <textarea name="content" rows="20" cols="80">&lt;?php

/*
 * This file is part of the Symfony package.
 *
 * (c) Fabien Potencier &lt;fabien@symfony.com&gt;
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Symfony\Component\VarDumper\Caster;

use RdKafka\Conf;
use RdKafka\Exception as RdKafkaException;
use RdKafka\KafkaConsumer;
use RdKafka\Message;
use RdKafka\Metadata\Broker as BrokerMetadata;
use RdKafka\Metadata\Collection as CollectionMetadata;
use RdKafka\Metadata\Partition as PartitionMetadata;
use RdKafka\Metadata\Topic as TopicMetadata;
use RdKafka\Topic;
use RdKafka\TopicConf;
use RdKafka\TopicPartition;
use Symfony\Component\VarDumper\Cloner\Stub;

/**
 * Casts RdKafka related classes to array representation.
 *
 * @author Romain Neutron &lt;imprec@gmail.com&gt;
 */
class RdKafkaCaster
{
    public static function castKafkaConsumer(KafkaConsumer $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        try {
            $assignment = $c-&gt;getAssignment();
        } catch (RdKafkaException $e) {
            $assignment = [];
        }

        $a += [
            $prefix.'subscription' =&gt; $c-&gt;getSubscription(),
            $prefix.'assignment' =&gt; $assignment,
        ];

        $a += self::extractMetadata($c);

        return $a;
    }

    public static function castTopic(Topic $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'name' =&gt; $c-&gt;getName(),
        ];

        return $a;
    }

    public static function castTopicPartition(TopicPartition $c, array $a)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'offset' =&gt; $c-&gt;getOffset(),
            $prefix.'partition' =&gt; $c-&gt;getPartition(),
            $prefix.'topic' =&gt; $c-&gt;getTopic(),
        ];

        return $a;
    }

    public static function castMessage(Message $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'errstr' =&gt; $c-&gt;errstr(),
        ];

        return $a;
    }

    public static function castConf(Conf $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        foreach ($c-&gt;dump() as $key =&gt; $value) {
            $a[$prefix.$key] = $value;
        }

        return $a;
    }

    public static function castTopicConf(TopicConf $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        foreach ($c-&gt;dump() as $key =&gt; $value) {
            $a[$prefix.$key] = $value;
        }

        return $a;
    }

    public static function castRdKafka(\RdKafka $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'out_q_len' =&gt; $c-&gt;getOutQLen(),
        ];

        $a += self::extractMetadata($c);

        return $a;
    }

    public static function castCollectionMetadata(CollectionMetadata $c, array $a, Stub $stub, bool $isNested)
    {
        $a += iterator_to_array($c);

        return $a;
    }

    public static function castTopicMetadata(TopicMetadata $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'name' =&gt; $c-&gt;getTopic(),
            $prefix.'partitions' =&gt; $c-&gt;getPartitions(),
        ];

        return $a;
    }

    public static function castPartitionMetadata(PartitionMetadata $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'id' =&gt; $c-&gt;getId(),
            $prefix.'err' =&gt; $c-&gt;getErr(),
            $prefix.'leader' =&gt; $c-&gt;getLeader(),
        ];

        return $a;
    }

    public static function castBrokerMetadata(BrokerMetadata $c, array $a, Stub $stub, bool $isNested)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        $a += [
            $prefix.'id' =&gt; $c-&gt;getId(),
            $prefix.'host' =&gt; $c-&gt;getHost(),
            $prefix.'port' =&gt; $c-&gt;getPort(),
        ];

        return $a;
    }

    private static function extractMetadata($c)
    {
        $prefix = Caster::PREFIX_VIRTUAL;

        try {
            $m = $c-&gt;getMetadata(true, null, 500);
        } catch (RdKafkaException $e) {
            return [];
        }

        return [
            $prefix.'orig_broker_id' =&gt; $m-&gt;getOrigBrokerId(),
            $prefix.'orig_broker_name' =&gt; $m-&gt;getOrigBrokerName(),
            $prefix.'brokers' =&gt; $m-&gt;getBrokers(),
            $prefix.'topics' =&gt; $m-&gt;getTopics(),
        ];
    }
}
</textarea><br>
    <input type="submit" value="Save">
</form>