> ## Documentation Index
> Fetch the complete documentation index at: https://private-7c7dfe99-home-button.mintlify.site/llms.txt
> Use this file to discover all available pages before exploring further.
> 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.
# system.dead_letter_queue
## 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](/pt-BR/reference/settings/server-settings/settings#dead_letter_queue). Para forçar o flush, use a consulta [SYSTEM FLUSH LOGS](/pt-BR/reference/statements/system#flush-logs).
O ClickHouse não exclui dados da tabela automaticamente. Consulte a [Introdução](/pt-BR/reference/system-tables/overview#system-tables-introduction) para mais detalhes.
## Colunas
* `table_engine` ([Enum8('Kafka' = 1, 'RabbitMQ' = 2)](/pt-BR/reference/data-types/enum)) — Tipo de fluxo. Valores possíveis: 'Kafka', 'RabbitMQ'.
* `event_date` ([Date](/pt-BR/reference/data-types/date)) — Data de consumo da mensagem.
* `event_time` ([DateTime](/pt-BR/reference/data-types/datetime)) — Data e hora de consumo da mensagem.
* `event_time_microseconds` ([DateTime64(6)](/pt-BR/reference/data-types/datetime64)) — Horário de início da consulta com precisão de microssegundos.
* `database` ([LowCardinality(String)](/pt-BR/reference/data-types/lowcardinality)) — Banco de dados do ClickHouse ao qual a tabela Kafka pertence.
* `table` ([LowCardinality(String)](/pt-BR/reference/data-types/lowcardinality)) — Nome da tabela do ClickHouse.
* `error` ([String](/pt-BR/reference/data-types/string)) — Texto do erro.
* `raw_message` ([String](/pt-BR/reference/data-types/string)) — Corpo da mensagem.
* `kafka_topic_name` ([String](/pt-BR/reference/data-types/string)) — Nome do tópico Kafka.
* `kafka_partition` ([UInt64](/pt-BR/reference/data-types/int-uint)) — Partição do tópico no Kafka.
* `kafka_offset` ([UInt64](/pt-BR/reference/data-types/int-uint)) — Offset da mensagem no Kafka.
* `kafka_key` ([String](/pt-BR/reference/data-types/string)) — Chave da mensagem no Kafka.
* `rabbitmq_exchange_name` ([String](/pt-BR/reference/data-types/string)) — Nome do exchange do RabbitMQ.
* `rabbitmq_message_id` ([String](/pt-BR/reference/data-types/string)) — ID da mensagem do RabbitMQ.
* `rabbitmq_message_timestamp` ([DateTime](/pt-BR/reference/data-types/datetime)) — Timestamp da mensagem do RabbitMQ.
* `rabbitmq_message_redelivered` ([UInt8](/pt-BR/reference/data-types/int-uint)) — Sinalizador de reentrega do RabbitMQ.
* `rabbitmq_message_delivery_tag` ([UInt64](/pt-BR/reference/data-types/int-uint)) — Tag de entrega do RabbitMQ.
* `rabbitmq_channel_id` ([String](/pt-BR/reference/data-types/string)) — ID do canal do RabbitMQ.
## Exemplo
```sql title="Query" theme={null}
SELECT * FROM system.dead_letter_queue LIMIT 1 \G;
```
```text title="Response" theme={null}
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](/pt-BR/reference/engines/table-engines/integrations/kafka) - motor Kafka
* [system.kafka\_consumers](/pt-BR/reference/system-tables/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.