From 077fad20ea88d00411a2b13762da337db7f801d9 Mon Sep 17 00:00:00 2001 From: Francis Cao Date: Mon, 27 Mar 2023 12:44:59 -0700 Subject: [PATCH] update skip_broken_messages --- db/clickhouse/schema.sql | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/db/clickhouse/schema.sql b/db/clickhouse/schema.sql index 904cd377..d754ac8b 100644 --- a/db/clickhouse/schema.sql +++ b/db/clickhouse/schema.sql @@ -66,7 +66,7 @@ SETTINGS kafka_broker_list = 'domain:9092,domain:9093,domain:9094', -- input bro kafka_group_name = 'event_consumer_group', kafka_format = 'JSONEachRow', kafka_max_block_size = 1048576, - kafka_skip_broken_messages = 1; + kafka_skip_broken_messages = 100; CREATE MATERIALIZED VIEW umami.event_queue_mv TO umami.event AS SELECT website_id, @@ -130,7 +130,7 @@ SETTINGS kafka_broker_list = 'domain:9092,domain:9093,domain:9094', -- input bro kafka_group_name = 'event_data_consumer_group', kafka_format = 'JSONEachRow', kafka_max_block_size = 1048576, - kafka_skip_broken_messages = 1; + kafka_skip_broken_messages = 100; CREATE MATERIALIZED VIEW umami.event_data_queue_mv TO umami.event_data AS SELECT website_id,