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:
Result:
See Also
- Kafka - Kafka エンジン
- system.kafka_consumers — Kafka コンシューマに関する統計やエラーの情報が含まれる
kafka_consumers
システムテーブルの説明。