説明
handle_error_mode 設定で dead_letter_queue を指定すると有効になります。
データのフラッシュ間隔は、サーバー設定の dead_letter_queue セクションにある flush_interval_milliseconds パラメータで設定します。フラッシュを強制するには、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)) — Kafka テーブルが属する 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 exchange 名。rabbitmq_message_id(String) — RabbitMQ メッセージ ID。rabbitmq_message_timestamp(DateTime) — RabbitMQ メッセージの timestamp。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 コンシューマーに関する統計情報やエラーなどの情報を含む、
kafka_consumersシステムテーブルの説明。