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

class 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(): 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