Skip to content

Class Metadata

Class \RdKafka\Metadata

Methods

__construct()

public __construct ( 
    \RdKafka $kafka, 
    bool $all_topics, 
    ?\RdKafka\Topic $only_topic, 
    int $timeout_ms
 ): 
Parameters
kafka \RdKafka
all_topics bool
only_topic ?\RdKafka\Topic
timeout_ms int

__destruct()

public __destruct (  ): 

getBrokers()

public getBrokers (  ): \RdKafka\Metadata\Collection|\RdKafka\Metadata\Broker[]
Returns
\RdKafka\Metadata\Collection|\RdKafka\Metadata\Broker[]

getOrigBrokerId()

public getOrigBrokerId (  ): int
Returns
int

getOrigBrokerName()

public getOrigBrokerName (  ): string
Returns
string

getTopics()

public getTopics (  ): \RdKafka\Metadata\Collection|\RdKafka\Metadata\Topic[]
Returns
\RdKafka\Metadata\Collection|\RdKafka\Metadata\Topic[]

Test Coverage 💚

  • 💚 Lines: 96.15% (50 / 52)
  • 💛 Methods: 81.82% (9 / 11)