clickhouse Kafka表引擎使用

2021-10-09 21:33:44 字數 849 閱讀 3913

centos 7

clickhouse-client-20.9.2.20-2.noarch.rpm

clickhouse-common-static-20.9.2.20-2.x86_64.rpm

clickhouse-server-20.9.2.20-2.noarch.rpm

#建立kafka表

create table if not exists testdb.kafka_queue (

......

) engine = kafka settings kafka_broker_list = '192.168.1.100:9092',

kafka_topic_list = 'test',

kafka_group_name = 'ch_consumer_group',

kafka_format = 'jsoneachrow',

kafka_max_block_size = 1048576,

kafka_thread_per_consumer = 1,

kafka_num_consumers = 4;

#建立物化檢視,將資料寫入儲存表

#下面語句中testdb.test_data_all是乙個分布式表

create materialized view testdb.kafka_queue_mv to testdb.test_data_all as

select ... from testdb.kafka_queue;

clickhouse 離線安裝

clickhouse 簡單集群搭建

kafka表引擎

參考文章1

參考文章2

mysql FEDERATED儲存引擎的使用

這個儲存引擎相當於db link,可以像訪問本地表一樣訪問遠端db的表。而且可以直接看到表資料。表結構的檔案放在本地db,表儲存內容檔案放在遠端,相當於呼叫遠端的表資料檔案。操作步驟 1 window 修改my.ini檔案。在最底下的 mysqld port 3306 federated 新增fed...

使系統錶可寫

以下示例將d列插入到a之後,b c之前 create table test a int,b int,c int select from test go 允許系統標更新 exec sp configure allow updates 1 goreconfigure with override go 新...

mysql修改表引擎

1.檢視mysql預設的表型別 show variables like default storage engine variable name value default storage engine innodb 1 row in set 0.00 sec 2.修改表的型別 alter tabl...