メインコンテンツまでスキップ
メインコンテンツまでスキップ

system.kafka_consumers

Querying in ClickHouse Cloud

このシステムテーブルのデータは、ClickHouse Cloudの各ノードにローカルで保管されています。そのため、すべてのデータの完全なビューを取得するには、clusterAllReplicas 関数が必要です。詳細については こちら をご覧ください。

Kafkaコンシューマに関する情報を含みます。 Kafkaテーブルエンジン（ネイティブClickHouse統合）に適用されます。

カラム：

  • database (String) - Kafkaエンジンを持つテーブルのデータベース。
  • table (String) - Kafkaエンジンを持つテーブルの名前。
  • consumer_id (String) - Kafkaコンシューマ識別子。テーブルは多くのコンシューマを持つことができる点に注意してください。これはkafka_num_consumersパラメータで指定されます。
  • assignments.topic (Array(String)) - Kafkaトピック。
  • assignments.partition_id (Array(Int32)) - KafkaパーティションID。1つのパーティションには1つのコンシューマのみが割り当てられる点に注意してください。
  • assignments.current_offset (Array(Int64)) - 現在のオフセット。
  • exceptions.time (Array(DateTime)) - 最も最近生成された10件の例外のタイムスタンプ。
  • exceptions.text (Array(String)) - 最も最近の10件の例外のテキスト。
  • last_poll_time (DateTime) - 最も最近のポーリングのタイムスタンプ。
  • num_messages_read (UInt64) - コンシューマが読み取ったメッセージの数。
  • last_commit_time (DateTime) - 最も最近のコミットのタイムスタンプ。
  • num_commits (UInt64) - コンシューマのコミット総数。
  • last_rebalance_time (DateTime) - 最も最近のKafkaのリバランスのタイムスタンプ。
  • num_rebalance_revocations (UInt64) - コンシューマからパーティションの権限が剥奪された回数。
  • num_rebalance_assignments (UInt64) - コンシューマがKafkaクラスターに割り当てられた回数。
  • is_currently_used (UInt8) - コンシューマが使用中
  • last_used (UInt64) - このコンシューマが最後に使用された時間、マイクロ秒のUnix時間
  • rdkafka_stat (String) - ライブラリ内部の統計。詳細はhttps://github.com/ClickHouse/librdkafka/blob/master/STATISTICS.mdを参照してください。`statistics_interval_ms`を0に設定すると無効化され、デフォルトは3000（3秒ごと）です。

例：