system.dead_letter_queue

Description

Contient des informations sur les messages reçus via un moteur de streaming et dont l’analyse a produit des erreurs. Actuellement implémenté pour Kafka et RabbitMQ. Disponibilité system.dead_letter_queue n’est créée que si la configuration du serveur contient une section dead_letter_queue. Le moteur de streaming doit également définir son paramètre handle_error_mode spécifique au moteur sur dead_letter_queue pour écrire les messages rejetés. Sans cette section dans la configuration du serveur, les requêtes sur la table échouent avec UNKNOWN_TABLE.

<clickhouse>
    <dead_letter_queue>
        <database>system</database>
        <table>dead_letter_queue</table>
        <partition_by>toYYYYMM(event_date)</partition_by>
        <flush_interval_milliseconds>7500</flush_interval_milliseconds>
    </dead_letter_queue>
</clickhouse>

La journalisation est activée en définissant dead_letter_queue pour le paramètre handle_error_mode spécifique au moteur. La période de vidage des données est définie par le paramètre flush_interval_milliseconds dans la section des paramètres serveur dead_letter_queue. Pour forcer le vidage, utilisez la requête SYSTEM FLUSH LOGS. ClickHouse ne supprime pas automatiquement les données de la table. Consultez Introduction pour plus de détails. Il est possible de tronquer ou de supprimer cette table à tout moment sans risque.

Colonnes

clickhouse_version (LowCardinality(String)) — Version du serveur ClickHouse qui a produit la ligne.
system_processor (LowCardinality(String)) — Architecture CPU du serveur ClickHouse qui a produit la ligne.
table_engine (Enum8(‘Kafka’ = 1, ‘RabbitMQ’ = 2)) — Type de flux. Valeurs possibles : ‘Kafka’, ‘RabbitMQ’.
event_date (Date) — Date de consommation du message.
event_time (DateTime) — Date et heure de consommation du message.
event_time_microseconds (DateTime64(6)) — Heure de début de la requête avec une précision à la microseconde.
database (LowCardinality(String)) — Base de données ClickHouse à laquelle appartient la table Kafka.
table (LowCardinality(String)) — Nom de la table ClickHouse.
error (String) — Texte de l’erreur.
raw_message (String) — Corps du message.
kafka_topic_name (String) — Nom du topic Kafka.
kafka_partition (UInt64) — Partition Kafka du topic.
kafka_offset (UInt64) — Offset Kafka du message.
kafka_key (String) — Clé Kafka du message.
rabbitmq_exchange_name (String) — Nom de l’exchange RabbitMQ.
rabbitmq_message_id (String) — ID du message RabbitMQ.
rabbitmq_message_timestamp (DateTime) — Horodatage du message RabbitMQ.
rabbitmq_message_redelivered (UInt8) — Indicateur de nouvelle livraison RabbitMQ.
rabbitmq_message_delivery_tag (UInt64) — Tag de livraison RabbitMQ.
rabbitmq_channel_id (String) — ID du canal RabbitMQ.

Exemple

Query

SELECT * FROM system.dead_letter_queue LIMIT 1 \G;

Response

Row 1:
──────
table_engine:                  Kafka
event_date:                    2025-05-01
event_time:                    2025-05-01 10:34:53
event_time_microseconds:       2025-05-01 10:34:53.910773
database:                      default
table:                         kafka
error:                         Cannot parse input: expected '\t' before: 'qwertyuiop': (at row 1)
:
Row 1:
Column 0,   name: key,   type: UInt64, ERROR: text "qwertyuiop" is not like UInt64
raw_message:                   qwertyuiop
kafka_topic_name:              TSV_dead_letter_queue_err_1746095689
kafka_partition:               0
kafka_offset:                  0
kafka_key:
rabbitmq_exchange_name:
rabbitmq_message_id:
rabbitmq_message_timestamp:    1970-01-01 00:00:00
rabbitmq_message_redelivered:  0
rabbitmq_message_delivery_tag: 0
rabbitmq_channel_id:

Row 2:
──────
table_engine:                  Kafka
event_date:                    2025-05-01
event_time:                    2025-05-01 10:34:53
event_time_microseconds:       2025-05-01 10:34:53.910944
database:                      default
table:                         kafka
error:                         Cannot parse input: expected '\t' before: 'asdfghjkl': (at row 1)
:
Row 1:
Column 0,   name: key,   type: UInt64, ERROR: text "asdfghjkl" is not like UInt64
raw_message:                   asdfghjkl
kafka_topic_name:              TSV_dead_letter_queue_err_1746095689
kafka_partition:               0
kafka_offset:                  0
kafka_key:
rabbitmq_exchange_name:
rabbitmq_message_id:
rabbitmq_message_timestamp:    1970-01-01 00:00:00
rabbitmq_message_redelivered:  0
rabbitmq_message_delivery_tag: 0
rabbitmq_channel_id:

Row 3:
──────
table_engine:                  Kafka
event_date:                    2025-05-01
event_time:                    2025-05-01 10:34:53
event_time_microseconds:       2025-05-01 10:34:53.911092
database:                      default
table:                         kafka
error:                         Cannot parse input: expected '\t' before: 'zxcvbnm': (at row 1)
:
Row 1:
Column 0,   name: key,   type: UInt64, ERROR: text "zxcvbnm" is not like UInt64
raw_message:                   zxcvbnm
kafka_topic_name:              TSV_dead_letter_queue_err_1746095689
kafka_partition:               0
kafka_offset:                  0
kafka_key:
rabbitmq_exchange_name:
rabbitmq_message_id:
rabbitmq_message_timestamp:    1970-01-01 00:00:00
rabbitmq_message_redelivered:  0
rabbitmq_message_delivery_tag: 0
rabbitmq_channel_id:
 (test.py:78, dead_letter_queue_test)

Voir aussi

Kafka - Moteur Kafka
system.kafka_consumers — Description de la table système kafka_consumers, qui contient notamment des statistiques et des erreurs concernant les consommateurs Kafka.

Référence SQL

Types de données

Moteurs

Fonctions

Formats

Paramètres

Tables système

Lacs de données

Description

Colonnes

Exemple

Voir aussi

​Description

​Colonnes

​Exemple

​Voir aussi

Description

Colonnes

Exemple

Voir aussi