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

system.kafka_consumers

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 秒ごとに 1 回）。

例: