Passer au contenu principal

​
Description

Contient des informations sur les messages reçus via un moteur de streaming et dont l’analyse a généré des erreurs. Actuellement implémenté pour Kafka et RabbitMQ. 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.

​
Colonnes

  • 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.
Dernière modification le 25 juin 2026