Interroger dans ClickHouse CloudLes données de cette table système sont stockées localement sur chaque nœud de ClickHouse Cloud. Pour obtenir une vue complète de l’ensemble des données, il faut donc utiliser la fonction
clusterAllReplicas. Consultez cette page pour plus de détails.Description
Colonnes
database(String) — Base de données de la table utilisant le moteur Kafka.table(String) — Nom de la table utilisant le moteur Kafka.consumer_id(String) — Identifiant du consommateur Kafka. Notez qu’une table peut avoir plusieurs consommateurs. Spécifié par le paramètrekafka_num_consumers.assignments.topic(Array(String)) — Kafka topic.assignments.partition_id(Array(Int32)) — ID de partition Kafka. Notez qu’un seul consommateur peut être affecté à une partition.assignments.current_offset(Array(Int64)) — Offset actuel.assignments.intent_size(Array(Nullable(Int64))) — Nombre de messages envoyés, mais pas encore validés, dans le nouveau StorageKafka.exceptions.time(Array(DateTime)) — Horodatage de génération des 10 exceptions les plus récentes.exceptions.text(Array(String)) — Texte des 10 exceptions les plus récentes.last_poll_time(DateTime) — Horodatage du poll le plus récent.num_messages_read(UInt64) — Nombre de messages lus par le consommateur.last_commit_time(DateTime) — Horodatage du poll le plus récent.num_commits(UInt64) — Nombre total de commits du consommateur.last_rebalance_time(DateTime) — Horodatage du rebalance Kafka le plus récent.num_rebalance_revocations(UInt64) — Nombre de fois où les partitions du consommateur ont été révoquées.num_rebalance_assignments(UInt64) — Nombre de fois où le consommateur a été affecté au cluster Kafka.is_currently_used(UInt8) — Indicateur signalant si le consommateur est actuellement utilisé.last_used(DateTime64(6)) — Dernière utilisation de ce consommateur.rdkafka_stat(String) — Statistique interne de la bibliothèque. Définissez statistics_interval_ms sur 0 pour la désactiver ; la valeur par défaut est 3000 (une fois toutes les trois secondes).dependencies(Array(Array(String))) — Dépendances transitives de la base de données.missing_dependencies(Array(Array(String))) — Dépendances transitives manquantes de la base de données.