The RdKafka\Consumer class

(PECL rdkafka >= 0.9.1)

Introduction

This is the low-level Kafka consumer. It can be used with Kafka >= 0.8.

RdKafka\Consumer extends RdKafka {

/* Methods */

public RdKafka\Queue newQueue ( void )

/* Inherited methods */

public RdKafka::addBrokers ( string $broker_list ) : integer

public RdKafka\Metadata RdKafka::getMetadata ( bool $all_topics , RdKafka\Topic|null $only_topic , int $timeout_ms )

public RdKafka::getOutQLen ( void ) : integer

public RdKafka\Topic RdKafka::newTopic ( string $topic_name [, RdKafka\TopicConf $topic_conf = NULL ] )

public RdKafka::poll ( integer $timeout_ms ) : void

public RdKafka::flush ( integer $timeout_ms ) : integer

public RdKafka::purge ( integer $purge_flags ) : integer

public RdKafka::setLogLevel ( integer $level ) : void

public RdKafka::setLogger ( integer $logger_id ) : void

public RdKafka::queryWatermarkOffsets ( string $topic , integer $partition , integer &$low , integer &$high , integer $timeout_ms ) : void

public RdKafka::offsetsForTimes ( array $topicPartitions , integer $timeout_ms ) : array

}