system.kafka_consumers
ClickHouse Cloud でのクエリ実行
このシステムテーブルのデータは、ClickHouse Cloud の各ノードにローカルに格納されています。そのため、すべてのデータを包括的に確認するには、clusterAllReplicas 関数を使用する必要があります。詳細についてはこちらを参照してください。
Kafka コンシューマーに関する情報を含みます。 Kafka table engine（ClickHouse ネイティブ統合）に適用されます。
カラム：
database(String) — Kafka Engine を使用するテーブルのデータベース。table(String) — Kafka Engine を使用するテーブル名。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)) — 現在のオフセット。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 リバランスのタイムスタンプ。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 秒に 1 回）です。dependencies(Array(Array(String))) — 推移的なデータベース依存関係。missing_dependencies(Array(Array(String))) — 欠落している推移的なデータベース依存関係。
例：
