system.dead_letter_queue

Tabela do sistema que contém informações sobre mensagens recebidas por meio de um engine de streaming e que apresentaram erros de análise.

​

Descrição

Contém informações sobre mensagens recebidas por um engine de streaming e que apresentaram erros de parsing. Atualmente implementado para Kafka e RabbitMQ.

O logging é habilitado ao especificar dead_letter_queue na configuração handle_error_mode específica do engine.

O intervalo de flush dos dados é definido no parâmetro flush_interval_milliseconds da seção de configurações do servidor dead_letter_queue. Para forçar o flush, use a consulta SYSTEM FLUSH LOGS.

O ClickHouse não exclui dados da tabela automaticamente. Consulte a Introdução para mais detalhes.

​

Colunas

• table_engine (Enum8(‘Kafka’ = 1, ‘RabbitMQ’ = 2)) — Tipo de fluxo. Valores possíveis: ‘Kafka’, ‘RabbitMQ’.
• event_date (Date) — Data de consumo da mensagem.
• event_time (DateTime) — Data e hora de consumo da mensagem.
• event_time_microseconds (DateTime64(6)) — Horário de início da consulta com precisão de microssegundos.
• database (LowCardinality(String)) — Banco de dados do ClickHouse ao qual a tabela Kafka pertence.
• table (LowCardinality(String)) — Nome da tabela do ClickHouse.
• error (String) — Texto do erro.
• raw_message (String) — Corpo da mensagem.
• kafka_topic_name (String) — Nome do tópico Kafka.
• kafka_partition (UInt64) — Partição do tópico no Kafka.
• kafka_offset (UInt64) — Offset da mensagem no Kafka.
• kafka_key (String) — Chave da mensagem no Kafka.
• rabbitmq_exchange_name (String) — Nome do exchange do RabbitMQ.
• rabbitmq_message_id (String) — ID da mensagem do RabbitMQ.
• rabbitmq_message_timestamp (DateTime) — Timestamp da mensagem do RabbitMQ.
• rabbitmq_message_redelivered (UInt8) — Sinalizador de reentrega do RabbitMQ.
• rabbitmq_message_delivery_tag (UInt64) — Tag de entrega do RabbitMQ.
• rabbitmq_channel_id (String) — ID do canal do RabbitMQ.

​

Exemplo

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)

​

Veja também

• Kafka - motor Kafka
• system.kafka_consumers — Descrição da tabela do sistema kafka_consumers, que contém informações como estatísticas e erros sobre os consumers do Kafka.