system.kafka_consumers

Contient des informations sur les consommateurs Kafka. S’applique au moteur de table Kafka (intégration native de ClickHouse)

• 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ètre kafka_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.

Exemple :

SELECT *
FROM system.kafka_consumers
FORMAT Vertical

Row 1:
──────
database:                      test
table:                         kafka
consumer_id:                   ClickHouse-instance-test-kafka-1caddc7f-f917-4bb1-ac55-e28bd103a4a0
assignments.topic:             ['system_kafka_cons']
assignments.partition_id:      [0]
assignments.current_offset:    [18446744073709550615]
exceptions.time:               []
exceptions.text:               []
last_poll_time:                2006-11-09 18:47:47
num_messages_read:             4
last_commit_time:              2006-11-10 04:39:40
num_commits:                   1
last_rebalance_time:           1970-01-01 00:00:00
num_rebalance_revocations:     0
num_rebalance_assignments:     1
is_currently_used:             1
rdkafka_stat:                  {...}
dependencies:                  [['test.mv2','test.target2'],['test.mv1','test.target1']]
missing_dependencies:          []