The RdKafka\Producer class

(PECL rdkafka >= 0.9.1)

Introduction

RdKafka\Producer extends RdKafka {

/* Methods */

public abortTransaction ( integer $timeout_ms ) : void

public beginTransaction ( void ) : void

public commitTransaction ( integer $timeout_ms ) : void

public initTransactions ( integer $timeout_ms ) : void

/* Inherited methods */

public RdKafka::addBrokers ( string $broker_list ) : integer

public RdKafka\Metadata RdKafka::getMetadata ( bool $all_topics , RdKafka\Topic|null $only_topic , int $timeout_ms )

public RdKafka::getOutQLen ( void ) : integer

public RdKafka\Topic RdKafka::newTopic ( string $topic_name [, RdKafka\TopicConf $topic_conf = NULL ] )

public RdKafka::poll ( integer $timeout_ms ) : void

public RdKafka::flush ( integer $timeout_ms ) : integer

public RdKafka::purge ( integer $purge_flags ) : integer

public RdKafka::setLogLevel ( integer $level ) : void

public RdKafka::setLogger ( integer $logger_id ) : void

public RdKafka::queryWatermarkOffsets ( string $topic , integer $partition , integer &$low , integer &$high , integer $timeout_ms ) : void

public RdKafka::offsetsForTimes ( array $topicPartitions , integer $timeout_ms ) : array

}