Class Consumer

Class \RdKafka\Consumer

• extends \RdKafka

Methods

__construct()

public __construct ( 
    ?\RdKafka\Conf $conf = null
 ): 

Parameters

conf ?\RdKafka\Conf

addBrokers()

public addBrokers ( 
    string $broker_list
 ): int

Parameters

broker_list string

Returns

int

getOutQLen()

public getOutQLen (  ): int

Returns

int

newQueue()

public newQueue (  ): \RdKafka\Queue

Returns

\RdKafka\Queue

newTopic()

public newTopic ( 
    string $topic_name, 
    ?\RdKafka\TopicConf $topic_conf = null
 ): \RdKafka\ConsumerTopic

Parameters

topic_name string

topic_conf ?\RdKafka\TopicConf

Returns

\RdKafka\ConsumerTopic

poll()

public poll ( 
    int $timeout_ms
 ): int

Parameters

timeout_ms int

Returns

int

Test Coverage 💚

• 💚 Lines: 100% (6 / 6)
• 💚 Methods: 100% (6 / 6)