The RdKafka\KafkaConsumerTopic class

(PECL rdkafka >= 1.0.0, librdkafka >= 0.9)

Introduction

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

Class synopsis

RdKafka\KafkaConsumerTopic extends RdKafka\Topic {
/* Methods */
public offsetStore ( integer $partition , integer $offset ) : void
/* Inherited methods */
public RdKafka\Topic::getName ( void ) : string
}

Table of Contents