The RdKafka class

(PECL rdkafka >= 0.9.1)

Introduction

This is the base class for low-level clients: RdKafka\Consumer, RdKafka\Producer. This class can not be instanciated directly, use one of the sub classes instead.

Class synopsis

RdKafka {
/* Methods */
public addBrokers ( string $broker_list ) : integer
public RdKafka\Metadata getMetadata ( bool $all_topics , RdKafka\Topic|null $only_topic , int $timeout_ms )
public getOutQLen ( void ) : integer
public RdKafka\Topic newTopic ( string $topic_name [, RdKafka\TopicConf $topic_conf = NULL ] )
public poll ( integer $timeout_ms ) : void
public flush ( integer $timeout_ms ) : integer
public purge ( integer $purge_flags ) : integer
public setLogLevel ( integer $level ) : void
public setLogger ( integer $logger_id ) : void
public queryWatermarkOffsets ( string $topic , integer $partition , integer &$low , integer &$high , integer $timeout_ms ) : void
public offsetsForTimes ( array $topicPartitions , integer $timeout_ms ) : array
}

Table of Contents