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。パーティションには一度に一つの消費者しか割り当てることができないことに注意してください。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) - ライブラリの内部統計。詳細は こちら を参照してください。statistics_interval_msを 0 に設定すると無効になり、デフォルトは 3000(3 秒ごとに 1 回)です。
例: