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;
```
投稿
微信公众账号
微信扫一扫加关注
评论 返回
顶部
发表评论 取消回复