ClickHouse Kafka 引擎与物化视图摄入实践

Kafka 源表与目标表：CREATE TABLE kafka_orders ( id UInt64, sku String, qty UInt32 ) ENGINE = Kafka SETTINGS kafka_broker_list = 'kafka:9092', kafka_topic_list = 'orders', kafka_group_name = 'ck-consumer', kafka_format = 'JSONEachRow', kafka_num_consumers = 1; CREATE TABLE orders ( id UInt64, sku LowCardinality(String), qty UInt32, ts DateTime DEFAULT now() ) ENGINE = MergeTree() PARTITION BY toYYYYMM(ts) ORDER BY (ts, id); 物化视图落盘：CREATE MATERIALIZED VIEW mv_orders TO orders AS SELECT id, sku, qty, now() AS ts FROM kafka_orders;