Skip to main content

​
Descrição

Contém informações sobre mensagens recebidas por um motor de streaming e que apresentaram erro de análise. Atualmente implementado para Kafka e RabbitMQ. Disponibilidade A system.dead_letter_queue é criada apenas quando a configuração do servidor contém uma seção dead_letter_queue. O motor de streaming também deve definir sua configuração específica handle_error_mode como dead_letter_queue para gravar as mensagens rejeitadas. Sem a seção de configuração do servidor, as consultas a essa tabela falham com UNKNOWN_TABLE.
O logging é habilitado ao especificar dead_letter_queue na configuração handle_error_mode específica do motor. 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. É seguro truncar ou remover esta tabela a qualquer momento.

​
Colunas

  • clickhouse_version (LowCardinality(String)) — Versão do servidor ClickHouse que produziu a linha.
  • system_processor (LowCardinality(String)) — Arquitetura de CPU do servidor ClickHouse que produziu a linha.
  • 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
Response

​
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.
Última modificação em 26 de setembro de 2026