create table load_test_stats ( run_id String, timestamp DateTime default now(), stats String ) engine = MergeTree PRIMARY KEY (run_id, timestamp) ORDER BY (run_id, timestamp) SETTINGS index_granularity = 8192; INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:06:05', '{"clickhouse": {"total_rows": "26620", "most_recent_event": "2024-03-29 14:51:15.741685", "lag_seconds": "890"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 1}], "lag": 1}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:06:10', '{"clickhouse": {"total_rows": "26621", "most_recent_event": "2024-03-29 15:06:03.421773", "lag_seconds": "7"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 11}], "lag": 11}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:06:15', '{"clickhouse": {"total_rows": "26633", "most_recent_event": "2024-03-29 15:06:10.844567", "lag_seconds": "5"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 205}], "lag": 205}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:06:20', '{"clickhouse": {"total_rows": "26645", "most_recent_event": "2024-03-29 15:06:11.198405", "lag_seconds": "9"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 428}], "lag": 428}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:06:25', '{"clickhouse": {"total_rows": "26658", "most_recent_event": "2024-03-29 15:06:11.592575", "lag_seconds": "14"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 711}], "lag": 711}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:06:30', '{"clickhouse": {"total_rows": "26670", "most_recent_event": "2024-03-29 15:06:11.950982", "lag_seconds": "19"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 950}], "lag": 950}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:06:35', '{"clickhouse": {"total_rows": "26682", "most_recent_event": "2024-03-29 15:06:12.195395", "lag_seconds": "23"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 939}], "lag": 939}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:06:40', '{"clickhouse": {"total_rows": "26694", "most_recent_event": "2024-03-29 15:06:12.572329", "lag_seconds": "28"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 927}], "lag": 927}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:06:45', '{"clickhouse": {"total_rows": "26706", "most_recent_event": "2024-03-29 15:06:12.780573", "lag_seconds": "33"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 915}], "lag": 915}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:06:50', '{"clickhouse": {"total_rows": "26719", "most_recent_event": "2024-03-29 15:06:13.013286", "lag_seconds": "37"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 902}], "lag": 902}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:06:55', '{"clickhouse": {"total_rows": "26731", "most_recent_event": "2024-03-29 15:06:13.289923", "lag_seconds": "42"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 890}], "lag": 890}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:00', '{"clickhouse": {"total_rows": "26743", "most_recent_event": "2024-03-29 15:06:13.499172", "lag_seconds": "47"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 878}], "lag": 878}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:05', '{"clickhouse": {"total_rows": "26755", "most_recent_event": "2024-03-29 15:06:13.722121", "lag_seconds": "52"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 866}], "lag": 866}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:10', '{"clickhouse": {"total_rows": "26768", "most_recent_event": "2024-03-29 15:06:13.979123", "lag_seconds": "57"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 853}], "lag": 853}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:15', '{"clickhouse": {"total_rows": "26780", "most_recent_event": "2024-03-29 15:06:14.226394", "lag_seconds": "61"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 841}], "lag": 841}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:20', '{"clickhouse": {"total_rows": "26793", "most_recent_event": "2024-03-29 15:06:14.602691", "lag_seconds": "66"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 828}], "lag": 828}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:25', '{"clickhouse": {"total_rows": "26805", "most_recent_event": "2024-03-29 15:06:14.862164", "lag_seconds": "71"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 816}], "lag": 816}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:30', '{"clickhouse": {"total_rows": "26817", "most_recent_event": "2024-03-29 15:06:15.433737", "lag_seconds": "75"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 804}], "lag": 804}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:35', '{"clickhouse": {"total_rows": "26830", "most_recent_event": "2024-03-29 15:06:15.678688", "lag_seconds": "80"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 791}], "lag": 791}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:40', '{"clickhouse": {"total_rows": "26842", "most_recent_event": "2024-03-29 15:06:15.907927", "lag_seconds": "85"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 779}], "lag": 779}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:45', '{"clickhouse": {"total_rows": "26855", "most_recent_event": "2024-03-29 15:06:16.287425", "lag_seconds": "89"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 766}], "lag": 766}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:50', '{"clickhouse": {"total_rows": "26867", "most_recent_event": "2024-03-29 15:06:16.493016", "lag_seconds": "94"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 754}], "lag": 754}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:07:55', '{"clickhouse": {"total_rows": "26879", "most_recent_event": "2024-03-29 15:06:17.165791", "lag_seconds": "98"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 742}], "lag": 742}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:00', '{"clickhouse": {"total_rows": "26892", "most_recent_event": "2024-03-29 15:06:17.412993", "lag_seconds": "103"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 729}], "lag": 729}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:05', '{"clickhouse": {"total_rows": "26904", "most_recent_event": "2024-03-29 15:06:17.586071", "lag_seconds": "108"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 717}], "lag": 717}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:10', '{"clickhouse": {"total_rows": "26916", "most_recent_event": "2024-03-29 15:06:17.789019", "lag_seconds": "113"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 705}], "lag": 705}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:15', '{"clickhouse": {"total_rows": "26929", "most_recent_event": "2024-03-29 15:06:18.035883", "lag_seconds": "117"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 692}], "lag": 692}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:20', '{"clickhouse": {"total_rows": "26941", "most_recent_event": "2024-03-29 15:06:18.348807", "lag_seconds": "122"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 680}], "lag": 680}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:25', '{"clickhouse": {"total_rows": "26954", "most_recent_event": "2024-03-29 15:06:18.602484", "lag_seconds": "127"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 667}], "lag": 667}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:30', '{"clickhouse": {"total_rows": "26966", "most_recent_event": "2024-03-29 15:06:18.791689", "lag_seconds": "132"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 655}], "lag": 655}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:35', '{"clickhouse": {"total_rows": "26978", "most_recent_event": "2024-03-29 15:06:19.072490", "lag_seconds": "136"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 643}], "lag": 643}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:41', '{"clickhouse": {"total_rows": "26991", "most_recent_event": "2024-03-29 15:06:19.357968", "lag_seconds": "141"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 630}], "lag": 630}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:46', '{"clickhouse": {"total_rows": "27003", "most_recent_event": "2024-03-29 15:06:19.551694", "lag_seconds": "146"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 618}], "lag": 618}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:51', '{"clickhouse": {"total_rows": "27016", "most_recent_event": "2024-03-29 15:06:19.880602", "lag_seconds": "152"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 605}], "lag": 605}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:08:56', '{"clickhouse": {"total_rows": "27028", "most_recent_event": "2024-03-29 15:06:20.184690", "lag_seconds": "156"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 593}], "lag": 593}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:01', '{"clickhouse": {"total_rows": "27040", "most_recent_event": "2024-03-29 15:06:20.358989", "lag_seconds": "161"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 581}], "lag": 581}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:06', '{"clickhouse": {"total_rows": "27053", "most_recent_event": "2024-03-29 15:06:20.526071", "lag_seconds": "166"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 568}], "lag": 568}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:11', '{"clickhouse": {"total_rows": "27065", "most_recent_event": "2024-03-29 15:06:20.715244", "lag_seconds": "171"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 556}], "lag": 556}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:16', '{"clickhouse": {"total_rows": "27077", "most_recent_event": "2024-03-29 15:06:20.894845", "lag_seconds": "176"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 544}], "lag": 544}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:21', '{"clickhouse": {"total_rows": "27090", "most_recent_event": "2024-03-29 15:06:21.184327", "lag_seconds": "180"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 531}], "lag": 531}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:26', '{"clickhouse": {"total_rows": "27102", "most_recent_event": "2024-03-29 15:06:21.371186", "lag_seconds": "185"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 519}], "lag": 519}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:31', '{"clickhouse": {"total_rows": "27115", "most_recent_event": "2024-03-29 15:06:21.549382", "lag_seconds": "190"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 506}], "lag": 506}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:36', '{"clickhouse": {"total_rows": "27127", "most_recent_event": "2024-03-29 15:06:21.709096", "lag_seconds": "195"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 494}], "lag": 494}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:41', '{"clickhouse": {"total_rows": "27139", "most_recent_event": "2024-03-29 15:06:21.891222", "lag_seconds": "200"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 482}], "lag": 482}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:46', '{"clickhouse": {"total_rows": "27151", "most_recent_event": "2024-03-29 15:06:22.132685", "lag_seconds": "204"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 470}], "lag": 470}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:51', '{"clickhouse": {"total_rows": "27164", "most_recent_event": "2024-03-29 15:06:22.350710", "lag_seconds": "209"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 457}], "lag": 457}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:09:56', '{"clickhouse": {"total_rows": "27176", "most_recent_event": "2024-03-29 15:06:22.515342", "lag_seconds": "214"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 445}], "lag": 445}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:01', '{"clickhouse": {"total_rows": "27188", "most_recent_event": "2024-03-29 15:06:22.703066", "lag_seconds": "219"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 433}], "lag": 433}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:06', '{"clickhouse": {"total_rows": "27201", "most_recent_event": "2024-03-29 15:06:22.865105", "lag_seconds": "224"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 420}], "lag": 420}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:11', '{"clickhouse": {"total_rows": "27213", "most_recent_event": "2024-03-29 15:06:23.114040", "lag_seconds": "228"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 408}], "lag": 408}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:16', '{"clickhouse": {"total_rows": "27226", "most_recent_event": "2024-03-29 15:06:23.366823", "lag_seconds": "233"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 395}], "lag": 395}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:21', '{"clickhouse": {"total_rows": "27238", "most_recent_event": "2024-03-29 15:06:23.595899", "lag_seconds": "238"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 383}], "lag": 383}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:26', '{"clickhouse": {"total_rows": "27250", "most_recent_event": "2024-03-29 15:06:23.808110", "lag_seconds": "243"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 371}], "lag": 371}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:31', '{"clickhouse": {"total_rows": "27263", "most_recent_event": "2024-03-29 15:06:24.009833", "lag_seconds": "247"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 358}], "lag": 358}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:36', '{"clickhouse": {"total_rows": "27275", "most_recent_event": "2024-03-29 15:06:24.187357", "lag_seconds": "252"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 346}], "lag": 346}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:41', '{"clickhouse": {"total_rows": "27288", "most_recent_event": "2024-03-29 15:06:24.440499", "lag_seconds": "257"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 333}], "lag": 333}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:46', '{"clickhouse": {"total_rows": "27300", "most_recent_event": "2024-03-29 15:06:24.659266", "lag_seconds": "262"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 321}], "lag": 321}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:51', '{"clickhouse": {"total_rows": "27312", "most_recent_event": "2024-03-29 15:06:24.829098", "lag_seconds": "267"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 309}], "lag": 309}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:10:56', '{"clickhouse": {"total_rows": "27325", "most_recent_event": "2024-03-29 15:06:25.064760", "lag_seconds": "271"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 296}], "lag": 296}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:01', '{"clickhouse": {"total_rows": "27337", "most_recent_event": "2024-03-29 15:06:25.266024", "lag_seconds": "276"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 284}], "lag": 284}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:06', '{"clickhouse": {"total_rows": "27350", "most_recent_event": "2024-03-29 15:06:25.508127", "lag_seconds": "281"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 271}], "lag": 271}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:11', '{"clickhouse": {"total_rows": "27362", "most_recent_event": "2024-03-29 15:06:25.693324", "lag_seconds": "286"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 259}], "lag": 259}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:16', '{"clickhouse": {"total_rows": "27374", "most_recent_event": "2024-03-29 15:06:25.924491", "lag_seconds": "291"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 247}], "lag": 247}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:21', '{"clickhouse": {"total_rows": "27387", "most_recent_event": "2024-03-29 15:06:26.197801", "lag_seconds": "295"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 234}], "lag": 234}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:26', '{"clickhouse": {"total_rows": "27399", "most_recent_event": "2024-03-29 15:06:26.416307", "lag_seconds": "300"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 222}], "lag": 222}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:31', '{"clickhouse": {"total_rows": "27411", "most_recent_event": "2024-03-29 15:06:26.646087", "lag_seconds": "305"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 210}], "lag": 210}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:36', '{"clickhouse": {"total_rows": "27423", "most_recent_event": "2024-03-29 15:06:27.287133", "lag_seconds": "309"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 198}], "lag": 198}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:41', '{"clickhouse": {"total_rows": "27434", "most_recent_event": "2024-03-29 15:06:27.489121", "lag_seconds": "314"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 187}], "lag": 187}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:46', '{"clickhouse": {"total_rows": "27446", "most_recent_event": "2024-03-29 15:06:27.739622", "lag_seconds": "319"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 176}], "lag": 176}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:51', '{"clickhouse": {"total_rows": "27456", "most_recent_event": "2024-03-29 15:06:27.892928", "lag_seconds": "324"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 165}], "lag": 165}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:11:56', '{"clickhouse": {"total_rows": "27465", "most_recent_event": "2024-03-29 15:06:28.104259", "lag_seconds": "328"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 156}], "lag": 156}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:01', '{"clickhouse": {"total_rows": "27474", "most_recent_event": "2024-03-29 15:06:28.237949", "lag_seconds": "333"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 147}], "lag": 147}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:06', '{"clickhouse": {"total_rows": "27484", "most_recent_event": "2024-03-29 15:06:28.394250", "lag_seconds": "338"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 137}], "lag": 137}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:11', '{"clickhouse": {"total_rows": "27493", "most_recent_event": "2024-03-29 15:06:28.564286", "lag_seconds": "343"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 128}], "lag": 128}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:16', '{"clickhouse": {"total_rows": "27505", "most_recent_event": "2024-03-29 15:06:28.738637", "lag_seconds": "348"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 116}], "lag": 116}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:21', '{"clickhouse": {"total_rows": "27517", "most_recent_event": "2024-03-29 15:06:29.009394", "lag_seconds": "352"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 104}], "lag": 104}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:26', '{"clickhouse": {"total_rows": "27529", "most_recent_event": "2024-03-29 15:06:29.273457", "lag_seconds": "357"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 92}], "lag": 92}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:31', '{"clickhouse": {"total_rows": "27542", "most_recent_event": "2024-03-29 15:06:29.502888", "lag_seconds": "362"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 79}], "lag": 79}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:36', '{"clickhouse": {"total_rows": "27554", "most_recent_event": "2024-03-29 15:06:29.743170", "lag_seconds": "367"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 67}], "lag": 67}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:41', '{"clickhouse": {"total_rows": "27566", "most_recent_event": "2024-03-29 15:06:29.909508", "lag_seconds": "372"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 55}], "lag": 55}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:46', '{"clickhouse": {"total_rows": "27578", "most_recent_event": "2024-03-29 15:06:30.155916", "lag_seconds": "376"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 43}], "lag": 43}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:51', '{"clickhouse": {"total_rows": "27590", "most_recent_event": "2024-03-29 15:06:30.322415", "lag_seconds": "381"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 31}], "lag": 31}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:12:56', '{"clickhouse": {"total_rows": "27602", "most_recent_event": "2024-03-29 15:06:30.542059", "lag_seconds": "386"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 19}], "lag": 19}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:13:01', '{"clickhouse": {"total_rows": "27615", "most_recent_event": "2024-03-29 15:06:30.733112", "lag_seconds": "391"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 6}], "lag": 6}}'); INSERT INTO event_sink.load_test_stats (run_id, timestamp, stats) VALUES ('e9d952', '2024-03-29 15:13:06', '{"clickhouse": {"total_rows": "27621", "most_recent_event": "2024-03-29 15:06:30.886450", "lag_seconds": "396"}, "kafka_bus": {"topic": "dev-analytics", "partitions": [{"partition": 0, "lag": 0}], "lag": 0}}');