The RdKafka\ProducerTopic class

(PECL rdkafka >= 0.9.1)

Introduction

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

Class synopsis

class RdKafka\ProducerTopic extends RdKafka\Topic {
/* Methods */
public produce(
    integer $partition,
    integer $msgflags,
    string $payload = NULL,
    string $key = NULL,
    string $opaque = NULL
): void
public producev(
    integer $partition,
    integer $msgflags,
    string $payload,
    string $key = NULL,
    array $headers = NULL,
    integer $timestamp_ms = NULL,
    string $opaque = NULL
): void
/* Inherited methods */
public RdKafka\Topic::getName(): string
}

Table of Contents