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

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

Table of Contents