事前定義された定数

以下の定数はこの拡張によって定義され、拡張がPHPにコンパイルされるか動的に実行時にロードされるかのどちらかの場合にのみ利用可能でしょう。

RD_KAFKA_CONSUMER (integer)

RD_KAFKA_OFFSET_BEGINNING (integer)

kafkaパーティションキューの最初からの消費を開始する: 最も古いメッセージ。

RD_KAFKA_OFFSET_END (integer)

kafkaパーティションキューの最後から消費を開始する: 最も新しいメッセージ。

RD_KAFKA_OFFSET_STORED (integer)

オフセットストアから取り出されたオフセットから消費を開始する。

RD_KAFKA_PARTITION_UA (integer)

割り当てられていないパーティションは、設定されたあるいはデフォルトのパーティショナーを使ってパーティションされなければならないメッセージのために、プロデューサAPIによって使われます。

RD_KAFKA_PRODUCER (integer)

RD_KAFKA_VERSION (integer)

RD_KAFKA_RESP_ERR__BEGIN (integer)

RD_KAFKA_RESP_ERR__BAD_MSG (integer)

ローカル: 有効ではないメッセージ形式

RD_KAFKA_RESP_ERR__BAD_COMPRESSION (integer)

ローカル: 無効な圧縮されたデータ

RD_KAFKA_RESP_ERR__DESTROY (integer)

ローカル: ブローカーのハンドルが破棄された

RD_KAFKA_RESP_ERR__FAIL (integer)

ローカル: ブローカーとの通信エラー

RD_KAFKA_RESP_ERR__TRANSPORT (integer)

ローカル: ブローカーの転送エラー

RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE (integer)

ローカル: 致命的なシステムのリソース障害

RD_KAFKA_RESP_ERR__RESOLVE (integer)

ローカル: ホストの解決の失敗

RD_KAFKA_RESP_ERR__MSG_TIMED_OUT (integer)

ローカル: メッセージのタイムアウト

RD_KAFKA_RESP_ERR__PARTITION_EOF (integer)

ブローカー: もうメッセージが無い

RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION (integer)

ローカル: 不明なパーティション

RD_KAFKA_RESP_ERR__FS (integer)

ローカル: ファイルまたはファイルシステムのエラー

RD_KAFKA_RESP_ERR__UNKNOWN_TOPIC (integer)

ローカル: 不明なトピック

RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN (integer)

ローカル: 全てのブローカーの接続がダウン

RD_KAFKA_RESP_ERR__INVALID_ARG (integer)

ローカル: 無効な引数または設定

RD_KAFKA_RESP_ERR__TIMED_OUT (integer)

ローカル: タイムアウト

RD_KAFKA_RESP_ERR__QUEUE_FULL (integer)

ローカル: キューが一杯

RD_KAFKA_RESP_ERR__ISR_INSUFF (integer)

ローカル: ISR のカウントが不十分

RD_KAFKA_RESP_ERR__NODE_UPDATE (integer)

ローカル: ブローカーのノードが更新された

RD_KAFKA_RESP_ERR__SSL (integer)

ローカル: SSL エラー

RD_KAFKA_RESP_ERR__WAIT_COORD (integer)

ローカル: コーディネーター待ち

RD_KAFKA_RESP_ERR__UNKNOWN_GROUP (integer)

ローカル: 不明なグループ

RD_KAFKA_RESP_ERR__IN_PROGRESS (integer)

ローカル: 進行中のオペレーション

RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS (integer)

ローカル: 進行中の以前のオペレーション

RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION (integer)

ローカル: 既存の購読

RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS (integer)

ローカル: パーティションの割り当て

RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS (integer)

ローカル: パーティションの取り消し

RD_KAFKA_RESP_ERR__CONFLICT (integer)

ローカル: 使用の衝突

RD_KAFKA_RESP_ERR__STATE (integer)

ローカル: 誤った状態

RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL (integer)

ローカル: 不明なプロトコル

RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED (integer)

ローカル: 未実装

RD_KAFKA_RESP_ERR__AUTHENTICATION (integer)

ローカル: 認証失敗

RD_KAFKA_RESP_ERR__NO_OFFSET (integer)

ローカル: オフセットが格納されていない

RD_KAFKA_RESP_ERR__END (integer)

RD_KAFKA_RESP_ERR_UNKNOWN (integer)

不明なブローカーのエラー

RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE (integer)

ブローカー: オフセットが範囲外

RD_KAFKA_RESP_ERR_INVALID_MSG (integer)

ブローカー: 無効なメッセージ

RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART (integer)

ブローカー: 不明なトピックあるいはパーティション

RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE (integer)

ブローカー: 無効なメッセージのサイズ

RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE (integer)

ブローカー: リーダーが利用不可

RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION (integer)

ブローカー: パーティションについてのリーダーでは無い

RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT (integer)

ブローカー: リクエストのタイムアウト

RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE (integer)

ブローカー: ブローカーが利用不可

RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE (integer)

ブローカー: レプリカが利用不可

RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE (integer)

ブローカー: メッセージサイズが長すぎる

RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH (integer)

ブローカー: StaleControllerEpochCode

RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE (integer)

ブローカー: オフセットのメタデータ文字列が長すぎる

RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION (integer)

ブローカー: 応答が受け取られる前にブローカーが切断された

RD_KAFKA_RESP_ERR_GROUP_LOAD_IN_PROGRESS (integer)

ブローカー: グループのコーディネータがロードを進行中

RD_KAFKA_RESP_ERR_GROUP_COORDINATOR_NOT_AVAILABLE (integer)

ブローカー: グループコーディネータが利用不可

RD_KAFKA_RESP_ERR_NOT_COORDINATOR_FOR_GROUP (integer)

ブローカー: グループについてのコーディネータでは無い

RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION (integer)

ブローカー: 無効なトピック

RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE (integer)

ブローカー: メッセージのバッチが設定されたサーバセグメントのサイズより大きい

RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS (integer)

ブローカー: 十分なin-syncレプリカが無い

RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND (integer)

ブローカー: 不十分な数のin-syncレプリカにメッセージが書き込まれた

RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS (integer)

ブローカー: 無効なacks値の要求

RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION (integer)

ブローカー: 指定されたグループの生成idが無効

RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL (integer)

ブローカー: 矛盾したグループ プロトコル

RD_KAFKA_RESP_ERR_INVALID_GROUP_ID (integer)

ブローカー: 無効なgroup.id

RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID (integer)

ブローカー: 不明なメンバー

RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT (integer)

ブローカー: 無効なセッションのタイムアウト

RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS (integer)

ブローカー: グループのリバランスが進行中

RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE (integer)

ブローカー: コミットしたオフセットのデータサイズが無効

RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED (integer)

ブローカー: トピックに認証が失敗

RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED (integer)

ブローカー: グループの認証が失敗

RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED (integer)

ブローカー: クラスタの認証が失敗

RD_KAFKA_CONF_UNKNOWN (integer)

RD_KAFKA_CONF_INVALID (integer)

RD_KAFKA_CONF_OK (integer)

RD_KAFKA_MSG_PARTITIONER_RANDOM (integer)

ランダムなパーティショナー。これはlibrdkafka 0.8ではデフォルトのパーティショナーでした。パーティションをランダムに割り当てます。

RD_KAFKA_MSG_PARTITIONER_CONSISTENT (integer)

首尾一貫したパーティショナー。全く同じキーを全く同じパーティションにマップするために一貫性のあるハッシュを使う。ハッシュ関数としてCRC32を使う。キーが無い、あるいは空のキーを持つメッセージは常に同じパーティションに割り当てられる。

RD_KAFKA_LOG_PRINT (integer)

ロガーの出力。メッセージをstderrに出力する。

RD_KAFKA_LOG_SYSLOG (integer)

syslogロガー。メッセージをsyslogに送信する。

RD_KAFKA_LOG_SYSLOG_PRINT (integer)

syslog-print パーティショナー。メッセージをsyslogに送信し、それらをstderrに出力する。