ClickHouse Cloud でのクエリこのシステムテーブルのデータは、ClickHouse Cloud の各ノードにローカルに保持されています。したがって、すべてのデータを完全に把握するには、
clusterAllReplicas 関数を使用する必要があります。詳細については、こちらを参照してください。説明
カラム
database(String) — Kafka Engine を使用するテーブルのデータベース。table(String) — Kafka Engine を使用するテーブル名。consumer_id(String) — Kafka コンシューマーの識別子。なお、1 つのテーブルに複数のコンシューマーを持たせることができます。kafka_num_consumersパラメータで指定します。assignments.topic(Array(String)) — Kafka トピック。assignments.partition_id(Array(Int32)) — Kafka パーティション ID。なお、1 つのパーティションに割り当てられるコンシューマーは 1 つだけです。assignments.current_offset(Array(Int64)) — 現在のオフセット。assignments.intent_size(Array(Nullable(Int64))) — 新しい StorageKafka でプッシュ済みだが、まだコミットされていないメッセージ数。exceptions.time(Array(DateTime)) — 直近 10 件の例外が生成された時刻のタイムスタンプ。exceptions.text(Array(String)) — 直近 10 件の例外のテキスト。last_poll_time(DateTime) — 直近の poll のタイムスタンプ。num_messages_read(UInt64) — コンシューマーが読み取ったメッセージ数。last_commit_time(DateTime) — 直近の poll のタイムスタンプ。num_commits(UInt64) — コンシューマーのコミット総数。last_rebalance_time(DateTime) — 直近の Kafka rebalance のタイムスタンプ。num_rebalance_revocations(UInt64) — コンシューマーのパーティション割り当てが取り消された回数。num_rebalance_assignments(UInt64) — コンシューマーが Kafka クラスターに割り当てられた回数。is_currently_used(UInt8) — コンシューマーが現在使用中かどうかを示すフラグ。last_used(DateTime64(6)) — このコンシューマーが最後に使用された時刻。rdkafka_stat(String) — ライブラリ内部の統計情報。statistics_interval_ms を 0 に設定すると無効になります。デフォルトは 3000 (3 秒ごと) です。dependencies(Array(Array(String))) — 推移的なデータベース依存関係。missing_dependencies(Array(Array(String))) — 欠落している推移的なデータベース依存関係。