描述
包含通过流式引擎接收且解析出错的消息信息。目前已针对 Kafka 和 RabbitMQ 实现。 可用性 只有当服务器配置中包含dead_letter_queue 部分时，才会创建 system.dead_letter_queue。此外，流式引擎还必须将其引擎特定的 handle_error_mode 设置为 dead_letter_queue，才能写入被拒绝的消息。若缺少该服务器配置部分，针对该表的查询将以 UNKNOWN_TABLE 失败。
handle_error_mode 设置指定为 dead_letter_queue 来启用日志记录。
数据的刷新周期在服务器设置部分 dead_letter_queue 的 flush_interval_milliseconds 参数中设置。要强制刷新，请使用 SYSTEM FLUSH LOGS 查询。
ClickHouse 不会自动从该表中删除数据。更多详情，请参阅 简介。
随时对该表执行 TRUNCATE 或 drop 操作都是安全的。
列
clickhouse_version(LowCardinality(String)) — 生成该行的 ClickHouse 服务器版本。system_processor(LowCardinality(String)) — 生成该行的 ClickHouse 服务器的 CPU 架构。table_engine(Enum8(‘Kafka’ = 1, ‘RabbitMQ’ = 2)) — 流类型。可能的值：‘Kafka’、‘RabbitMQ’。event_date(Date) — 消费消息的日期。event_time(DateTime) — 消费消息的日期和时间。event_time_microseconds(DateTime64(6)) — 查询开始时间，精度为微秒。database(LowCardinality(String)) — Kafka 表所属的 ClickHouse 数据库。table(LowCardinality(String)) — ClickHouse 表名。error(String) — 错误信息。raw_message(String) — 消息体。kafka_topic_name(String) — Kafka topic 名称。kafka_partition(UInt64) — topic 的 Kafka 分区。kafka_offset(UInt64) — 消息的 Kafka 偏移量。kafka_key(String) — 消息的 Kafka 键。rabbitmq_exchange_name(String) — RabbitMQ exchange 名称。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。
示例
Query
Response
另请参阅
- Kafka - Kafka 引擎
- system.kafka_consumers —
kafka_consumers系统表的说明，包含 Kafka 消费者的统计信息、错误等内容。