> ## Documentation Index
> Fetch the complete documentation index at: https://private-7c7dfe99-mintlify-8c05c8a2.mintlify.site/llms.txt
> Use this file to discover all available pages before exploring further.

> 스트리밍 엔진을 통해 수신되고 파싱 중 오류가 발생한 메시지에 대한 정보를 포함하는 시스템 테이블.

# system.dead_letter_queue

<div id="description">
  ## 설명
</div>

스트리밍 엔진을 통해 수신되었으며 파싱 중 오류가 발생한 메시지에 대한 정보를 포함합니다. 현재는 Kafka와 RabbitMQ에 대해 구현되어 있습니다.

엔진별 `handle_error_mode` 설정에 `dead_letter_queue`를 지정하면 로깅이 활성화됩니다.

데이터 플러시 주기는 [dead\_letter\_queue](/ko/reference/settings/server-settings/settings#dead_letter_queue) 서버 설정 섹션의 `flush_interval_milliseconds` 매개변수로 설정합니다. 강제로 플러시하려면 [SYSTEM FLUSH LOGS](/ko/reference/statements/system#flush-logs) 쿼리를 사용하십시오.

ClickHouse는 테이블의 데이터를 자동으로 삭제하지 않습니다. 자세한 내용은 [소개](/ko/reference/system-tables/overview#system-tables-introduction)를 참조하십시오.

<div id="columns">
  ## 컬럼
</div>

* `table_engine` ([Enum8('Kafka' = 1, 'RabbitMQ' = 2)](/ko/reference/data-types/enum)) — 스트림 유형입니다. 가능한 값: 'Kafka', 'RabbitMQ'.
* `event_date` ([Date](/ko/reference/data-types/date)) — 메시지를 소비한 날짜입니다.
* `event_time` ([DateTime](/ko/reference/data-types/datetime)) — 메시지를 소비한 날짜와 시간입니다.
* `event_time_microseconds` ([DateTime64(6)](/ko/reference/data-types/datetime64)) — 마이크로초 정밀도의 쿼리 시작 시간입니다.
* `database` ([LowCardinality(String)](/ko/reference/data-types/lowcardinality)) — Kafka 테이블이 속한 ClickHouse 데이터베이스입니다.
* `table` ([LowCardinality(String)](/ko/reference/data-types/lowcardinality)) — ClickHouse 테이블 이름입니다.
* `error` ([String](/ko/reference/data-types/string)) — 오류 텍스트입니다.
* `raw_message` ([String](/ko/reference/data-types/string)) — 메시지 본문입니다.
* `kafka_topic_name` ([String](/ko/reference/data-types/string)) — Kafka 토픽 이름입니다.
* `kafka_partition` ([UInt64](/ko/reference/data-types/int-uint)) — 토픽의 Kafka 파티션입니다.
* `kafka_offset` ([UInt64](/ko/reference/data-types/int-uint)) — 메시지의 Kafka 오프셋입니다.
* `kafka_key` ([String](/ko/reference/data-types/string)) — 메시지의 Kafka 키입니다.
* `rabbitmq_exchange_name` ([String](/ko/reference/data-types/string)) — RabbitMQ exchange 이름입니다.
* `rabbitmq_message_id` ([String](/ko/reference/data-types/string)) — RabbitMQ 메시지 ID입니다.
* `rabbitmq_message_timestamp` ([DateTime](/ko/reference/data-types/datetime)) — RabbitMQ 메시지 타임스탬프입니다.
* `rabbitmq_message_redelivered` ([UInt8](/ko/reference/data-types/int-uint)) — RabbitMQ 재전달 플래그입니다.
* `rabbitmq_message_delivery_tag` ([UInt64](/ko/reference/data-types/int-uint)) — RabbitMQ delivery tag입니다.
* `rabbitmq_channel_id` ([String](/ko/reference/data-types/int-uint)) — RabbitMQ 채널 ID입니다.

<div id="example">
  ## 예시
</div>

```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)

```

<div id="see-also">
  ## 관련 항목
</div>

* [Kafka](/ko/reference/engines/table-engines/integrations/kafka) - Kafka 엔진
* [system.kafka\_consumers](/ko/reference/system-tables/kafka_consumers) — Kafka 컨슈머에 대한 통계, 오류 등의 정보를 포함하는 `kafka_consumers` 시스템 테이블에 대한 설명입니다.