Rdkafka

RdKafka エクステンションは、kafka 0.8以上をサポートするPHPのためのKafkaクライアントを提供します。高レベルのKafkaConsumer と Producer、低レベルの Consumer、およびMetadata APIをサポートします。

インストール/設定
- 必要条件
- インストール
例
- High-level コンシューマ
- Low-level コンシューマ
- プロデューサ
Rdkafka 関数
- rd_kafka_err2str — rdkafkaのエラーコードを文字列に変換する
- rd_kafka_errno2err — system errno をkafkaのエラーコードに変換する
- rd_kafka_errno — system errnoを取得する
- rd_kafka_offset_tail — tailに相対的なKafkaのオフセット
RdKafka\KafkaConsumer — RdKafka\KafkaConsumer クラス
- RdKafka\KafkaConsumer::assign — 割り当てセットを更新する
- RdKafka\KafkaConsumer::commit — オフセットをコミットする
- RdKafka\KafkaConsumer::commitAsync — 非同期にオフセットをコミットする
- RdKafka\KafkaConsumer::__construct — コンストラクタ
- RdKafka\KafkaConsumer::consume — メッセージを消費し、コールバックを起動する
- RdKafka\KafkaConsumer::getAssignment — 現在のパーティションの割り当てを返す
- RdKafka\KafkaConsumer::getMetadata — ブローカーからのメタデータを要求する
- RdKafka\KafkaConsumer::getSubscription — 現在の購読を返す
- RdKafka\KafkaConsumer::subscribe — 購読セットを更新する
- RdKafka\KafkaConsumer::unsubscribe — 現在の購読セットから購読を止める
RdKafka\KafkaConsumerTopic — RdKafka\KafkaConsumerTopic クラス
- RdKafka\KafkaConsumerTopic::offsetStore — オフセットを格納する
RdKafka — RdKafka クラス
- RdKafka::addBrokers — ブローカーを追加する
- RdKafka::getMetadata — ブローカーからのメタデータを要求する
- RdKafka::getOutQLen — 出力キューの長さを取得する
- RdKafka::newQueue — 新しいメッセージキューのインスタンスを作成する
- RdKafka::newTopic — 新しいトピックのインスタンスを作成する
- RdKafka::poll — イベントのためのpoll
- RdKafka::setLogLevel — ログレベルを設定する
RdKafka\Consumer — RdKafka\Consumer クラス
- RdKafka\Consumer::__construct — コンストラクタ
RdKafka\Producer — RdKafka\Producer クラス
- RdKafka\Producer::__construct — コンストラクタ
RdKafka\Topic — RdKafka\Topic クラス
- RdKafka\Topic::getName — トピック名を取得する
RdKafka\ConsumerTopic — RdKafka\ConsumerTopic クラス
- RdKafka\ConsumerTopic::consume — パーティションから1つのメッセージを消費する
- RdKafka\ConsumerTopic::consumeQueueStart — パーティションをキューにパイプする
- RdKafka\ConsumerTopic::consumeStart — パーティションからのメッセージの消費を開始する
- RdKafka\ConsumerTopic::consumeStop — パーティションからのメッセージの消費を停止する
- RdKafka\ConsumerTopic::offsetStore — オフセットを格納する
RdKafka\ProducerTopic — RdKafka\ProducerTopic クラス
- RdKafka\ProducerTopic::produce — 1つのメッセージを生成し、送信する
RdKafka\Queue — RdKafka\Queue クラス
- RdKafka\Queue::consume — 1つのメッセージを消費する
RdKafka\Message — RdKafka\Message クラス
- RdKafka\Message::errstr — エラーを文字列として取得する
RdKafka\Conf — RdKafka\Conf クラス
- RdKafka\Conf::dump — 設定をダンプする
- RdKafka\Conf::set — 構成を設定する
- RdKafka\Conf::setDefaultTopicConf — デフォルトのトピックの構成を設定する
- RdKafka\Conf::setDrMsgCb — 配送レポートのコールバックを設定する
- RdKafka\Conf::setErrorCb — エラーのコールバックを設定する
- RdKafka\Conf::setRebalanceCb — リバランスのコールバックを設定する
RdKafka\TopicConf — RdKafka\TopicConf クラス
- RdKafka\TopicConf::dump — 設定をダンプする
- RdKafka\TopicConf::set — 構成を設定する
- RdKafka\TopicConf::setPartitioner — パーティショナーを設定する
RdKafka\Exception — RdKafka\Exception クラス
RdKafka\TopicPartition — RdKafka\TopicPartition クラス
- RdKafka\TopicPartition::__construct — コンストラクタ
- RdKafka\TopicPartition::getOffset — オフセットを取得する
- RdKafka\TopicPartition::getPartition — パーティションIDを取得する
- RdKafka\TopicPartition::getTopic — トピック名を取得する
- RdKafka\TopicPartition::setOffset — オフセットを設定する
- RdKafka\TopicPartition::setPartition — パーティションIDを設定する
- RdKafka\TopicPartition::setTopic — トピック名を設定する
RdKafka\Metadata — RdKafka\Metadata クラス
- RdKafka\Metadata::getBrokers — ブローカーのリストを取得する
- RdKafka\Metadata::getOrigBrokerId — このメタデータが由来するブローカーidを取得する
- RdKafka\Metadata::getOrigBrokerName — このメタデータが由来するブローカー名を取得する
- RdKafka\Metadata::getTopics — トピックのリストを取得する
RdKafka\Metadata\Collection — RdKafka\Metadata\Collection クラス
- RdKafka\Metadata\Collection::count — 要素を数える
- RdKafka\Metadata\Collection::current — 現在の値を取得する
- RdKafka\Metadata\Collection::key — 現在のキーを取得する
- RdKafka\Metadata\Collection::next — 次の要素に移動する
- RdKafka\Metadata\Collection::rewind — イテレータをrewindする
- RdKafka\Metadata\Collection::valid — 現在の位置が有効かどうかを調べる
事前定義された定数