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;
-