Description
dead_letter_queue pour le paramètre handle_error_mode spécifique au moteur.
La période de vidage des données est définie par le paramètre flush_interval_milliseconds dans la section des paramètres serveur dead_letter_queue. Pour forcer le vidage, utilisez la requête SYSTEM FLUSH LOGS.
ClickHouse ne supprime pas automatiquement les données de la table. Consultez Introduction pour plus de détails.
Colonnes
table_engine(Enum8(‘Kafka’ = 1, ‘RabbitMQ’ = 2)) — Type de flux. Valeurs possibles : ‘Kafka’, ‘RabbitMQ’.event_date(Date) — Date de consommation du message.event_time(DateTime) — Date et heure de consommation du message.event_time_microseconds(DateTime64(6)) — Heure de début de la requête avec une précision à la microseconde.database(LowCardinality(String)) — Base de données ClickHouse à laquelle appartient la table Kafka.table(LowCardinality(String)) — Nom de la table ClickHouse.error(String) — Texte de l’erreur.raw_message(String) — Corps du message.kafka_topic_name(String) — Nom du topic Kafka.kafka_partition(UInt64) — Partition Kafka du topic.kafka_offset(UInt64) — Offset Kafka du message.kafka_key(String) — Clé Kafka du message.rabbitmq_exchange_name(String) — Nom de l’exchange RabbitMQ.rabbitmq_message_id(String) — ID du message RabbitMQ.rabbitmq_message_timestamp(DateTime) — Horodatage du message RabbitMQ.rabbitmq_message_redelivered(UInt8) — Indicateur de nouvelle livraison RabbitMQ.rabbitmq_message_delivery_tag(UInt64) — Tag de livraison RabbitMQ.rabbitmq_channel_id(String) — ID du canal RabbitMQ.
Exemple
Query
Response
Voir aussi
- Kafka - Moteur Kafka
- system.kafka_consumers — Description de la table système
kafka_consumers, qui contient notamment des statistiques et des erreurs concernant les consommateurs Kafka.