The RdKafka\ConsumerTopic class

(PECL rdkafka >= 0.9.1)

Introduction

This class represents a topic when using RdKafka\Consumer. It can not be instantiated directly, RdKafka\Consumer::newTopic() should be used instead.

Class synopsis

RdKafka\ConsumerTopic extends RdKafka\Topic {
/* Methods */
public RdKafka\Message consume ( integer $partition , integer $timeout_ms )
public consumeBatch ( integer $partition , integer $timeout_ms , integer $batch_size ) : array
public consumeCallback ( integer $partition , integer $timeout_ms , callable $callback ) : void
public consumeQueueStart ( integer $partition , integer $offset , RdKafka\Queue $queue ) : void
public consumeStart ( integer $partition , integer $offset ) : void
public consumeStop ( integer $partition ) : void
public offsetStore ( integer $partition , integer $offset ) : void
/* Inherited methods */
public RdKafka\Topic::getName ( void ) : string
}

Table of Contents