RdKafka\Consumer クラス

(PECL rdkafka >= 0.9.1)

はじめに

これは低レベルのKafkaコンシューマです。Kafka >= 0.8 で使うことができます。

RdKafka\Consumer extends RdKafka {

/* メソッド */

/* 継承メソッド */

public integer RdKafka::addBrokers ( string $broker_list )

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

public integer RdKafka::getOutQLen ( void )

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

public void RdKafka::poll ( integer $timeout_ms )

public void RdKafka::setLogLevel ( integer $level )

}