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.

Class synopsis

class RdKafka\Consumer extends RdKafka {
/* Methods */
public RdKafka\Queue newQueue()
/* 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(): 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
}

Table of Contents