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

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

Table of Contents