system.dead_letter_queue

Contains information about messages received via a streaming engine and parsed with errors. Currently implemented for Kafka and RabbitMQ.

Logging is enabled by specifying dead_letter_queue for the engine specific handle_error_mode setting.

The flushing period of data is set in flush_interval_milliseconds parameter of the dead_letter_queue server settings section. To force flushing, use the SYSTEM FLUSH LOGS query.

ClickHouse does not delete data from the table automatically. See Introduction for more details.

Columns:

• table_engine (Enum8) - ストリームタイプ。可能な値: Kafka と RabbitMQ。
• event_date (Date) - メッセージ消費日。
• event_time (DateTime) - メッセージ消費日時。
• event_time_microseconds (DateTime64) - マイクロ秒精度のメッセージ消費時間。
• database (LowCardinality(String)) - ストリーミングテーブルが所属する ClickHouse データベース。
• table (LowCardinality(String)) - ClickHouse テーブル名。
• error (String) - エラーテキスト。
• raw_message (String) - メッセージ本体。
• kafka_topic_name (String) - Kafka トピック名。
• kafka_partition (UInt64) - トピックの Kafka パーティション。
• kafka_offset (UInt64) - メッセージの Kafka オフセット。
• kafka_key (String) - メッセージの Kafka キー。
• rabbitmq_exchange_name (String) - RabbitMQ エクスチェンジ名。
• rabbitmq_message_id (String) - RabbitMQ メッセージ ID。
• rabbitmq_message_timestamp (DateTime) - RabbitMQ メッセージのタイムスタンプ。
• rabbitmq_message_redelivered (UInt8) - RabbitMQ 再配達フラグ。
• rabbitmq_message_delivery_tag (UInt64) - RabbitMQ デリバリタグ。
• rabbitmq_channel_id (String) - RabbitMQ チャンネル ID。

Example

Query:

SELECT * FROM system.dead_letter_queue LIMIT 1 \G;

Result:

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)

See Also

• Kafka - Kafka エンジン
• system.kafka_consumers — Kafka コンシューマに関する統計やエラーの情報が含まれる kafka_consumers システムテーブルの説明。