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.
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.
SELECT * FROM system.dead_letter_queue LIMIT 1 \G;
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)
- 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 10 de junho de 2026
