RdKafka クラス

(PECL rdkafka >= 0.9.1)

はじめに

このクラスは低レベルのクライアントのための規定クラスです: RdKafka\Consumer, RdKafka\Producer。このクラスは直接インスタンス化することはできません。変わりに子クラスのうちの1つを使ってください。

RdKafka {

/* メソッド */

public integer addBrokers ( string $broker_list )

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

public integer getOutQLen ( void )

public RdKafka\Queue newQueue ( void )

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

public void poll ( integer $timeout_ms )

public void setLogLevel ( integer $level )

}