问题描述
我在 Kafka 主题中有一些数据,然后这些数据由 Clickhouse 获取并分发到表中。我有一张公用表,从中选择数据,第二张表用于连接Clickhouse和Kafka,第三张是物化视图,连接这两个表。
所以,这是我的第一个公用表:
CREATE TABLE click1
(typeId String,code String,time DateTime Codec(DoubleDelta,LZ4),date ALIAS toDate(time))
Engine = MergeTree
ORDER BY (typeId);
这是第二个,用于连接Kafka:
CREATE TABLE click2
(typeId String,time DateTime)
Engine = Kafka
SETTINGS kafka_broker_list = 'kafka:29092',kafka_topic_list = 'topk',kafka_group_name = 'group1',kafka_format = 'JSONEachRow',kafka_row_delimiter = '\n',kafka_max_block_size = 1048576;
物化视图:
CREATE MATERIALIZED VIEW clickhouse_mat TO click1 AS
SELECT typeId,code,time
FROM click2
Select all from table click1 返回以下内容:
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)