RdKafka\ConsumerTopic クラス

(PECL rdkafka >= 0.9.1)

はじめに

このクラスはRdKafka\Consumerを使う時のトピックを表します。直接インスタンス化することができません。代わりにRdKafka\Consumer::newTopic() が使われるべきです。

RdKafka\ConsumerTopic extends RdKafka\Topic {

/* メソッド */

public RdKafka\Message consume ( integer $partition , integer $timeout_ms )

public void consumeQueueStart ( integer $partition , integer $offset , RdKafka\Queue $queue )

public void consumeStart ( integer $partition , integer $offset )

public void consumeStop ( integer $partition )

public void offsetStore ( integer $partition , integer $offset )

/* 継承メソッド */

public string RdKafka\Topic::getName ( void )

}