Описание
dead_letter_queue для специфичного для движка параметра handle_error_mode.
Период сброса данных задается параметром flush_interval_milliseconds в разделе настроек сервера dead_letter_queue. Чтобы принудительно выполнить сброс, используйте запрос SYSTEM FLUSH LOGS.
ClickHouse не удаляет данные из таблицы автоматически. Подробнее см. в разделе Introduction.
Столбцы
table_engine(Enum8(‘Kafka’ = 1, ‘RabbitMQ’ = 2)) — Тип потока. Возможные значения: ‘Kafka’, ‘RabbitMQ’.event_date(Date) — Дата получения сообщения.event_time(DateTime) — Дата и время получения сообщения.event_time_microseconds(DateTime64(6)) — Время начала запроса с точностью до микросекунд.database(LowCardinality(String)) — База данных ClickHouse, которой принадлежит таблица Kafka.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) — Имя exchange в RabbitMQ.rabbitmq_message_id(String) — Идентификатор сообщения RabbitMQ.rabbitmq_message_timestamp(DateTime) — Временная метка сообщения RabbitMQ.rabbitmq_message_redelivered(UInt8) — Флаг повторной доставки в RabbitMQ.rabbitmq_message_delivery_tag(UInt64) — Тег доставки RabbitMQ.rabbitmq_channel_id(String) — Идентификатор канала RabbitMQ.
Пример
Query
Response
См. также
- Kafka - движок Kafka
- system.kafka_consumers — Описание системной таблицы
kafka_consumers, содержащей сведения, включая статистику и ошибки потребителей Kafka.