From 12704c81e5ceeff69a5235a4bed5933f1476617a Mon Sep 17 00:00:00 2001 From: Brian Cao Date: Wed, 31 Aug 2022 21:44:49 -0700 Subject: [PATCH] set experiment. --- db/clickhouse/migrations/01_init/migration.sql | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/db/clickhouse/migrations/01_init/migration.sql b/db/clickhouse/migrations/01_init/migration.sql index 2cca9b84..5a1df775 100644 --- a/db/clickhouse/migrations/01_init/migration.sql +++ b/db/clickhouse/migrations/01_init/migration.sql @@ -1,3 +1,5 @@ +SET allow_experimental_object_type = 1; + -- Create Pageview CREATE TABLE pageview ( @@ -19,7 +21,7 @@ CREATE TABLE pageview_queue ( referrer String ) ENGINE = Kafka -SETTINGS kafka_broker_list = 'localhost:9092,localhost:9093,localhost:9094', -- input broker list +SETTINGS kafka_broker_list = 'kafka1:19092,kafka2:19093,kafka3:19094', -- input broker list kafka_topic_list = 'pageview', kafka_group_name = 'pageview_consumer_group', kafka_format = 'JSONEachRow', @@ -65,7 +67,7 @@ CREATE TABLE session_queue ( country LowCardinality(String) ) ENGINE = Kafka -SETTINGS kafka_broker_list = 'localhost:9092,localhost:9093,localhost:9094', -- input broker list +SETTINGS kafka_broker_list = 'kafka1:19092,kafka2:19093,kafka3:19094', -- input broker list kafka_topic_list = 'session', kafka_group_name = 'session_consumer_group', kafka_format = 'JSONEachRow', @@ -110,7 +112,7 @@ CREATE TABLE event_queue ( event_data String ) ENGINE = Kafka -SETTINGS kafka_broker_list = 'localhost:9092,localhost:9093,localhost:9094', -- input broker list +SETTINGS kafka_broker_list = 'kafka1:19092,kafka2:19093,kafka3:19094', -- input broker list kafka_topic_list = 'event', kafka_group_name = 'event_consumer_group', kafka_format = 'JSONEachRow', @@ -126,4 +128,3 @@ SELECT event_uuid, event_name, event_data FROM event_queue; -