== containers ==
posthog-worker-1	posthog/posthog:latest	Up 6 minutes
posthog-temporal-django-worker-1	posthog/posthog:latest	Up 2 hours
posthog-web-1	posthog/posthog:latest	Up 2 hours
posthog-proxy-1	caddy	Up 6 hours
posthog-plugins-1	posthog/posthog-node:latest	Up 2 hours
posthog-ingestion-general-1	posthog/posthog-node:latest	Up 2 hours
posthog-recording-api-1	posthog/posthog-node:latest	Up 2 hours
posthog-property-defs-rs-1	ghcr.io/posthog/posthog/property-defs-rs:master	Up 2 hours
posthog-cymbal-1	ghcr.io/posthog/posthog/cymbal:master	Up 2 hours
posthog-temporal-admin-tools-1	temporalio/admin-tools:1.26.2	Up 2 hours
posthog-ingestion-sessionreplay-1	posthog/posthog-node:latest	Up 2 hours
posthog-ingestion-logs-1	posthog/posthog-node:latest	Up 2 hours
posthog-ingestion-error-tracking-1	posthog/posthog-node:latest	Up 2 hours
posthog-ingestion-traces-1	posthog/posthog-node:latest	Up 2 hours
posthog-temporal-ui-1	temporalio/ui:2.47.2	Up 2 hours
posthog-personhog-router-1	ghcr.io/posthog/posthog/personhog-router:master	Up 6 hours
posthog-clickhouse-1	clickhouse/clickhouse-server:26.6.2.158	Up 6 hours (healthy)
posthog-livestream-1	ghcr.io/posthog/posthog/livestream:master	Up 6 hours
posthog-kafka-init-1	redpandadata/redpanda:v25.1.9	Exited (0) 7 seconds ago
posthog-temporal-1	temporalio/auto-setup:1.26.2	Up 2 hours (healthy)
posthog-personhog-replica-1	ghcr.io/posthog/posthog/personhog-replica:master	Up 6 hours
posthog-cymbal-resolution-1	ghcr.io/posthog/posthog/cymbal:master	Up 6 hours
posthog-feature-flags-1	ghcr.io/posthog/posthog/feature-flags:master	Up 2 hours (healthy)
posthog-hypercache-server-1	ghcr.io/posthog/posthog/hypercache-server:master	Up 2 hours (healthy)
posthog-kafka-1	redpandadata/redpanda:v25.1.9	Up 2 hours (healthy)
posthog-db-1	postgres:15.12-alpine	Up 2 hours (healthy)
posthog-browserless-1	ghcr.io/browserless/chromium:v2.51.2	Up 2 hours
posthog-redis7-1	redis:7.2-alpine	Up 2 hours (healthy)
seaweedfs-main	chrislusf/seaweedfs:4.29	Up 6 hours (healthy)
posthog-elasticsearch-1	elasticsearch:7.17.28	Up 2 hours (healthy)
posthog-valkey-1	valkey/valkey:8.1-alpine	Up 2 hours (healthy)
posthog-replay-capture-1	ghcr.io/posthog/posthog/capture:master	Up 2 hours
posthog-objectstorage-1	minio/minio:RELEASE.2025-04-22T22-12-26Z	Up 2 hours
posthog-capture-logs-1	ghcr.io/posthog/posthog/capture-logs:master	Up 6 hours
posthog-zookeeper-1	zookeeper:3.7.0	Up 6 hours
posthog-capture-1	ghcr.io/posthog/posthog/capture:master	Up 2 hours
== Caddyfile (proxy) ==
{

}
localhost, http://, https:// {
    @replay-capture {
        path /s
        path /s/
        path /s/*
    }

    @capture-ai {
        path /i/v0/ai
        path /i/v0/ai/
        path /i/v0/ai/*
    }

    @capture {
        path /e
        path /e/
        path /e/*
        path /i/v0
        path /i/v0/
        path /i/v0/*
        path /i/v1/analytics/events
        path /i/v1/analytics/events/
        path /batch
        path /batch/
        path /batch/*
        path /capture
        path /capture/
        path /capture/*
    }

    @capture-logs {
        path /i/v1/logs
        path /i/v1/logs/
        path /i/v1/logs/*
        path /i/v1/traces
        path /i/v1/traces/
        path /i/v1/traces/*
        path /i/v1/metrics
        path /i/v1/metrics/
        path /i/v1/metrics/*
    }

    @flags {
        path /flags
        path /flags/
        path /flags/*
        # Local evaluation (flag definitions) — mirrors cloud Contour routing to Rust
        path /api/feature_flag/local_evaluation
        path /api/feature_flag/local_evaluation/
        path /api/feature_flag/local_evaluation/*
    }

    @surveys {
        path /surveys
        path /surveys/
        path /api/surveys
        path /api/surveys/
    }

    @remote-config {
        path /array/*
    }

    @webhooks {
        path /public/webhooks
        path /public/webhooks/
        path /public/webhooks/*
        path /public/m/
        path /public/m/*
    }

    @livestream {
        path /livestream
        path /livestream/
        path /livestream/*
    }

    handle @livestream {
        uri strip_prefix /livestream
        reverse_proxy livestream:8080 {
            flush_interval -1
        }
    }

    handle @capture-ai {
        reverse_proxy capture-ai:3000
    }

    handle @capture {
        reverse_proxy capture:3000
    }

    handle @replay-capture {
        reverse_proxy replay-capture:3000
    }

    handle @capture-logs {
        reverse_proxy capture-logs:4318
    }

    handle @flags {
        reverse_proxy feature-flags:3001
    }

    handle @surveys {
        reverse_proxy hypercache-server:3002
    }

    handle @remote-config {
        reverse_proxy hypercache-server:3002
    }

    handle @webhooks {
        reverse_proxy plugins:6738
    }

    @objectstorage {
        path /posthog
        path /posthog/
        path /posthog/*
    }

    handle @objectstorage {
        reverse_proxy objectstorage:19000
    }

    handle {
        reverse_proxy web:8000
    }
}


== capture env ==
CAPTURE_MODE=events
CAPTURE_V1_SINK_MSK_KAFKA_TOPIC_EXCEPTION=ingestion-errortracking-main
CAPTURE_V1_SINK_MSK_KAFKA_TOPIC_MAIN=events_plugin_ingestion
CAPTURE_V1_SINK_MSK_KAFKA_TOPIC_CLIENT_INGESTION_WARNING=ingestion-clientwarnings-main-1
KAFKA_TOPIC=events_plugin_ingestion
ADDRESS=0.0.0.0:3000
CAPTURE_V1_SINK_MSK_KAFKA_TOPIC_OVERFLOW=events_plugin_ingestion_overflow
RUST_LOG=info,rdkafka=warn
CAPTURE_V1_SINK_MSK_KAFKA_HOSTS=kafka:9092
CAPTURE_V1_SINK_MSK_KAFKA_TOPIC_HISTORICAL=events_plugin_ingestion_historical
REDIS_URL=redis://redis7:6379/
CAPTURE_V1_SINK_MSK_KAFKA_TOPIC_DLQ=events_plugin_ingestion_dlq
CAPTURE_V1_SINKS=msk
CAPTURE_V1_SINK_MSK_KAFKA_TOPIC_HEATMAP=heatmaps_ingestion
KAFKA_HOSTS=kafka:9092
KAFKA_ERROR_TRACKING_TOPIC=ingestion-errortracking-main
PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin
BIN=capture

== plugin-server modes ==
posthog-plugins-1 
posthog-ingestion-general-1 
posthog-recording-api-1 
posthog-ingestion-sessionreplay-1 
posthog-ingestion-logs-1 
posthog-ingestion-error-tracking-1 
posthog-ingestion-traces-1 
== restart policies ==
posthog-proxy-1 always
posthog-capture-1 on-failure
posthog-ingestion-general-1 on-failure
posthog-plugins-1 on-failure
posthog-kafka-1 on-failure
posthog-clickhouse-1 on-failure
== kafka consumer groups ==
BROKER  GROUP                                    STATE
0       cdp-batch-hogflow-requests-consumer      Stable
0       cdp-cohort-membership-consumer           Stable
0       cdp-cyclotron-hog-consumer               Stable
0       cdp-cyclotron-hogflow-consumer           Stable
0       cdp-internal-events-consumer             Stable
0       cdp-person-updates-consumer              Stable
0       cdp-precalculated-filters-consumer       Stable
0       cdp-processed-events-consumer            Stable
0       clickhouse-ingestion                     Stable
0       clickhouse-ingestion-historical          Stable
0       clickhouse-ingestion-overflow            Stable
0       clickhouse-person-distinct-id-overrides  Stable
0       clickhouse_app_metrics2_ws               Stable
0       clickhouse_cohort_membership_changed     Stable
0       clickhouse_events_json_native_json       Stable
0       clickhouse_flag_evaluations              Stable
0       clickhouse_ingestion_warnings_v2         Stable
0       clickhouse_log_entries                   Stable
0       clickhouse_log_entries_ws                Stable
0       clickhouse_tophog                        Stable
0       clickhouse_tophog_ws                     Stable
0       clickhouse_usage_report_events_preagg    Stable
0       client_iwarnings_ingestion               Stable
0       evaluation-scheduler                     Stable
0       group1                                   Stable
0       heatmaps_ingestion                       Stable
0       ingestion-errortracking                  Stable
0       ingestion-logs                           Stable
0       ingestion-traces                         Stable
0       livestream                               Stable
0       livestream-session-recordings            Stable
0       property-defs-rs                         Stable
0       session-recordings-blob-v2               Stable
GROUP        cdp-batch-hogflow-requests-consumer
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                       PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
cdp_batch_hogflow_requests  0          -               0                 0               -     9cfa311bbb5c-467a6ddc-07a3-40fc-9ba8-d23a947c21d0  9cfa311bbb5c  172.19.0.5
GROUP        cdp-cohort-membership-consumer
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                      PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
cohort_membership_changed  0          -               0                 0               -     9cfa311bbb5c-d1735138-933e-4570-a157-16171b1a02a4  9cfa311bbb5c  172.19.0.5
GROUP        cdp-cyclotron-hog-consumer
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC              PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
cdp_cyclotron_hog  0          -               0                 0               -     9cfa311bbb5c-6c63e76d-e2ee-452f-ae60-d43e3609a32f  9cfa311bbb5c  172.19.0.5
GROUP        cdp-cyclotron-hogflow-consumer
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                  PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
cdp_cyclotron_hogflow  0          -               0                 0               -     9cfa311bbb5c-33c62bb9-b699-4f97-8c88-336dd575e5d1  9cfa311bbb5c  172.19.0.5
GROUP        cdp-internal-events-consumer
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
cdp_internal_events  0          2               0                 2               0     9cfa311bbb5c-3ad822ff-0ed9-40cb-a587-4230e8b3b311  9cfa311bbb5c  172.19.0.5
GROUP        cdp-person-updates-consumer
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC              PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
clickhouse_person  0          -               0                 0               -     9cfa311bbb5c-4d5ef8f4-0604-45a3-b617-54270d6b2d58  9cfa311bbb5c  172.19.0.5
GROUP        cdp-precalculated-filters-consumer
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                   PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
clickhouse_events_json  0          -               0                 0               -     9cfa311bbb5c-cb8028a5-a4a3-4041-94f0-a4d6c1079609  9cfa311bbb5c  172.19.0.5
GROUP        cdp-processed-events-consumer
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                   PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
clickhouse_events_json  0          -               0                 0               -     9cfa311bbb5c-b8558709-1e67-468c-bda9-5cc0e36a03e3  9cfa311bbb5c  172.19.0.5
GROUP        clickhouse-ingestion
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                    PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
events_plugin_ingestion  0          -               0                 0               -     d32662636613-0910c3ef-32f1-42e1-bd53-3b57ba14bbab  d32662636613  172.19.0.28
GROUP        clickhouse-ingestion-historical
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                               PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
events_plugin_ingestion_historical  0          -               0                 0               -     d32662636613-d37e6ac0-25c9-4669-8bd8-449214ce80a2  d32662636613  172.19.0.28
GROUP        clickhouse-ingestion-overflow
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                             PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
events_plugin_ingestion_overflow  0          -               0                 0               -     d32662636613-0edd56a0-f5c4-4b2e-ab64-f034481d607e  d32662636613  172.19.0.28
GROUP        clickhouse-person-distinct-id-overrides
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC                          PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                                                CLIENT-ID                                                           HOST
clickhouse_person_distinct_id  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_person_distinct_id_overrides-d4e11d44-cc3e-4b1a-8bd4-41295aac26aa  ClickHouse-dddf867935e2-posthog-kafka_person_distinct_id_overrides  172.19.0.14
GROUP        clickhouse_app_metrics2_ws
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC                    PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                                   CLIENT-ID                                              HOST
clickhouse_app_metrics2  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_app_metrics2_ws-921ade86-b218-44c1-a36a-906527e7f5ca  ClickHouse-dddf867935e2-posthog-kafka_app_metrics2_ws  172.19.0.14
GROUP        clickhouse_cohort_membership_changed
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC                      PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                                     CLIENT-ID                                                HOST
cohort_membership_changed  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_cohort_membership-71b9b754-739a-422b-a9da-a4c946bcb83d  ClickHouse-dddf867935e2-posthog-kafka_cohort_membership  172.19.0.14
GROUP        clickhouse_events_json_native_json
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC                   PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                                           CLIENT-ID                                                      HOST
clickhouse_events_json  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_events_json_native_json-65d2673a-08b8-4c00-bd08-266ce62bcfeb  ClickHouse-dddf867935e2-posthog-kafka_events_json_native_json  172.19.0.14
GROUP        clickhouse_flag_evaluations
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC                        PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                                    CLIENT-ID                                               HOST
clickhouse_flag_evaluations  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_flag_evaluations-133548ab-42a9-4e1d-beee-f5871dfd3414  ClickHouse-dddf867935e2-posthog-kafka_flag_evaluations  172.19.0.14
GROUP        clickhouse_ingestion_warnings_v2
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC                          PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                                         CLIENT-ID                                                    HOST
clickhouse_ingestion_warnings  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_ingestion_warnings_v2-94cbc53e-d105-4862-bca3-f67edb67bfe0  ClickHouse-dddf867935e2-posthog-kafka_ingestion_warnings_v2  172.19.0.14
GROUP        clickhouse_log_entries
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC        PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                                  CLIENT-ID                                             HOST
log_entries  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_log_entries_v3-9b016026-78d4-4dd1-8fe9-873042f88e3b  ClickHouse-dddf867935e2-posthog-kafka_log_entries_v3  172.19.0.14
GROUP        clickhouse_log_entries_ws
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC        PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                                  CLIENT-ID                                             HOST
log_entries  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_log_entries_ws-36777b74-2698-47d5-ae86-707c2067a026  ClickHouse-dddf867935e2-posthog-kafka_log_entries_ws  172.19.0.14
GROUP        clickhouse_tophog
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC              PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                          CLIENT-ID                                     HOST
clickhouse_tophog  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_tophog-107e0f2d-26d9-40ca-b372-d4b2b642385b  ClickHouse-dddf867935e2-posthog-kafka_tophog  172.19.0.14
GROUP        clickhouse_tophog_ws
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC              PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                             CLIENT-ID                                        HOST
clickhouse_tophog  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_tophog_ws-f4d8a626-3c74-40e3-9f03-26863aa98d94  ClickHouse-dddf867935e2-posthog-kafka_tophog_ws  172.19.0.14
GROUP        clickhouse_usage_report_events_preagg
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC                   PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                                              CLIENT-ID                                                         HOST
clickhouse_events_json  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_usage_report_events_preagg-d14c5e70-6690-4569-8d83-1f3b89c1d0a8  ClickHouse-dddf867935e2-posthog-kafka_usage_report_events_preagg  172.19.0.14
GROUP        client_iwarnings_ingestion
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                       PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
client_iwarnings_ingestion  0          -               0                 0               -     d32662636613-2a0392db-3325-410d-838f-7e316f060e60  d32662636613  172.19.0.28
GROUP        evaluation-scheduler
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                   PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
clickhouse_events_json  0          -               0                 0               -     9cfa311bbb5c-5d80e63b-7205-4ce7-a2db-4871c3ba0b68  9cfa311bbb5c  172.19.0.5
GROUP        group1
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      8
TOTAL-LAG    0

TOPIC                          PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                                                                       CLIENT-ID                                                  HOST
clickhouse_ai_events_json      0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_ai_events_json-1c716042-b173-4789-bc58-89bbbf1e733a       ClickHouse-dddf867935e2-posthog-kafka_ai_events_json       172.19.0.14
clickhouse_app_metrics2        0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_app_metrics2-a500be69-2b69-4d0c-8903-1ca67507f657         ClickHouse-dddf867935e2-posthog-kafka_app_metrics2         172.19.0.14
clickhouse_events_json         0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_events_json-a669448c-116b-406e-a150-c2f46dc41d93          ClickHouse-dddf867935e2-posthog-kafka_events_json          172.19.0.14
clickhouse_groups              0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_groups-9f576d47-c96c-4e3f-b404-db16fb96d824               ClickHouse-dddf867935e2-posthog-kafka_groups               172.19.0.14
clickhouse_heatmap_events      0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_heatmaps-daa59d58-51e0-4ec6-88a1-3a4bb59a43d6             ClickHouse-dddf867935e2-posthog-kafka_heatmaps             172.19.0.14
clickhouse_ingestion_warnings  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_ingestion_warnings-2fa76024-c365-427f-be67-a75ca91b0084   ClickHouse-dddf867935e2-posthog-kafka_ingestion_warnings   172.19.0.14
clickhouse_person              0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_person-de8bf7f8-f49c-4b4f-b417-138fe9630fc5               ClickHouse-dddf867935e2-posthog-kafka_person               172.19.0.14
clickhouse_person_distinct_id  0          -               0                 0               -     ClickHouse-dddf867935e2-posthog-kafka_person_distinct_id2-29af8ffa-1610-4d54-b33e-c3679a231b6d  ClickHouse-dddf867935e2-posthog-kafka_person_distinct_id2  172.19.0.14
GROUP        heatmaps_ingestion
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC               PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
heatmaps_ingestion  0          -               0                 0               -     d32662636613-432b1573-2a6f-4795-a8a3-3665c0a4f310  d32662636613  172.19.0.28
GROUP        ingestion-errortracking
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                         PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
ingestion-errortracking-main  0          -               0                 0               -     7b9052c052d1-10756545-667d-448c-aa4d-f2accb34f292  7b9052c052d1  172.19.0.7
GROUP        ingestion-logs
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      2
TOTAL-LAG    0

TOPIC           PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
logs_ingestion  0          -               0                 0               -     91e4fe35ea88-a0ea997f-02d7-4807-b574-754f920c5a54  91e4fe35ea88  172.19.0.8
GROUP        ingestion-traces
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC             PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
ingestion-traces  0          -               0                 0               -     9b2f0c8c18c6-a18ba386-0733-41e8-9626-2c331bd16e7e  9b2f0c8c18c6  172.19.0.25
GROUP        livestream
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC                    PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                     CLIENT-ID  HOST
events_plugin_ingestion  0          -               0                 0               -     rdkafka-93d886b7-761b-4ff2-a69d-88b2a11bd16f  rdkafka    172.19.0.12
GROUP        livestream-session-recordings
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC                                   PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                     CLIENT-ID  HOST
session_recording_snapshot_item_events  0          -               0                 0               -     rdkafka-c629a235-fb0b-4693-8f8a-0ee988dd3050  rdkafka    172.19.0.12
GROUP        property-defs-rs
COORDINATOR  0
STATE        Stable
BALANCER     range
MEMBERS      1
TOTAL-LAG    0

TOPIC                   PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                     CLIENT-ID  HOST
clickhouse_events_json  0          -               0                 0               -     rdkafka-3b72c356-c61d-48c2-8269-54ff894966d3  rdkafka    172.19.0.30
GROUP        session-recordings-blob-v2
COORDINATOR  0
STATE        Stable
BALANCER     cooperative-sticky
MEMBERS      1
TOTAL-LAG    0

TOPIC                                   PARTITION  CURRENT-OFFSET  LOG-START-OFFSET  LOG-END-OFFSET  LAG   MEMBER-ID                                          CLIENT-ID     HOST
session_recording_snapshot_item_events  0          -               0                 0               -     352ec070cb01-b048623d-fc7b-4653-b273-171a0f1d91c1  352ec070cb01  172.19.0.27
== kafka topics ==
NAME                                    PARTITIONS  REPLICAS
cdp_batch_hogflow_requests              1           1
cdp_cyclotron_hog                       1           1
cdp_cyclotron_hogflow                   1           1
cdp_internal_events                     1           1
clickhouse_ai_events_json               1           1
clickhouse_app_metrics2                 1           1
clickhouse_events_json                  1           1
clickhouse_flag_evaluations             1           1
clickhouse_groups                       1           1
clickhouse_heatmap_events               1           1
clickhouse_ingestion_warnings           1           1
clickhouse_person                       1           1
clickhouse_person_distinct_id           1           1
clickhouse_tophog                       1           1
client_iwarnings_ingestion              1           1
cohort_membership_changed               1           1
events_plugin_ingestion                 1           1
events_plugin_ingestion_ai              1           1
events_plugin_ingestion_async           1           1
events_plugin_ingestion_dlq             1           1
events_plugin_ingestion_historical      1           1
events_plugin_ingestion_overflow        1           1
heatmaps_ingestion                      1           1
ingestion-clientwarnings-main-1         1           1
ingestion-errortracking-main            1           1
ingestion-traces                        1           1
log_entries                             1           1
logs_ingestion                          1           1
session_recording_snapshot_item_events  1           1
== clickhouse tables ==
adhoc_events_deletion
ai_events
ai_events_json_mv
app_metrics
app_metrics2
app_metrics2_mv
app_metrics2_ws_mv
app_metrics_mv
billing_usage_records
billing_usage_records_mv
channel_definition
channel_definition_dict
clickhouse_cleanup_deleted_persons
clickhouse_cleanup_orphaned_distinct_ids
clickhouse_cleanup_revived_distinct_ids
clickhouse_cleanup_revived_persons
cohort_membership
cohort_membership_mv
cohortpeople
conversion_goal_attributed_preaggregated
custom_metrics
custom_metrics_counter_events
custom_metrics_counters
custom_metrics_events_recent_lag
custom_metrics_replication_queue
custom_metrics_server_crash
custom_metrics_table_sizes
custom_metrics_test
distinct_id_usage
distinct_id_usage_mv
distributed_events_recent
distributed_posthog_document_embeddings
distributed_posthog_document_embeddings_text_embedding_3_large_3072
distributed_posthog_document_embeddings_text_embedding_3_small_1536
distributed_system_processes
duplicate_events
duplicate_events_mv
error_tracking_fingerprint_issue_state
error_tracking_fingerprint_issue_state_mv
error_tracking_issue_fingerprint_overrides
error_tracking_issue_fingerprint_overrides_mv
events
events_batch_export
events_batch_export_backfill
events_batch_export_recent
events_batch_export_unbounded
events_dead_letter_queue
events_dead_letter_queue_mv
events_json
events_json_mv
events_json_table_mv
events_recent
events_recent_json_mv
exchange_rate
exchange_rate_dict
experiment_exposures_preaggregated
experiment_metric_events_preaggregated
flag_evaluations
flag_evaluations_mv
groups
groups_mv
heatmaps
heatmaps_mv
hog_invocation_results
hog_invocation_results_data
hog_invocation_results_mv
infi_clickhouse_orm_migrations
infi_clickhouse_orm_migrations_distributed
ingestion_warnings
ingestion_warnings_mv
ingestion_warnings_v2
ingestion_warnings_v2_distributed
ingestion_warnings_v2_mv
kafka_ai_events_json
kafka_app_metrics
kafka_app_metrics2
kafka_app_metrics2_ws
kafka_billing_usage_records
kafka_cohort_membership
kafka_distinct_id_usage
kafka_duplicate_events
kafka_error_tracking_fingerprint_issue_state
kafka_error_tracking_issue_fingerprint_overrides
kafka_events_dead_letter_queue
kafka_events_json
kafka_events_json_native_json
kafka_flag_evaluations
kafka_groups
kafka_heatmaps
kafka_hog_invocation_results
kafka_ingestion_warnings
kafka_ingestion_warnings_v2
kafka_log_entries_v3
kafka_log_entries_ws
kafka_logs34_avro_mv
kafka_logs_avro
kafka_logs_avro_billing_metrics_mv
kafka_logs_avro_kafka_metrics_mv
kafka_message_assets
kafka_metrics_avro
kafka_metrics_avro_kafka_metrics_mv
kafka_metrics_avro_mv
kafka_metrics_avro_to_metric_samples
kafka_metrics_avro_to_metric_series
kafka_performance_events
kafka_person
kafka_person_distinct_id
kafka_person_distinct_id2
kafka_person_distinct_id_overrides
kafka_person_overrides
kafka_plugin_log_entries
kafka_posthog_document_embeddings
kafka_precalculated_events
kafka_precalculated_person_properties
kafka_property_values
kafka_session_replay_events
kafka_session_replay_features
kafka_tophog
kafka_tophog_ws
kafka_trace_spans_avro
kafka_trace_spans_avro_mv
kafka_usage_report_events_preagg
llma_metrics_daily
log_attributes
log_attributes2
log_attributes3
log_attributes_distributed
log_entries
log_entries_v3_mv
log_entries_ws_mv
logs
logs32
logs32_to_log_attributes
logs32_to_resource_attributes
logs34
logs34_to_log_attributes3
logs34_to_resource_attributes3
logs34_to_volume_buckets
logs_billing_metrics
logs_billing_metrics_distributed
logs_distributed
logs_kafka_metrics
logs_kafka_metrics_distributed
logs_pattern_buckets
logs_pattern_buckets_distributed
logs_volume_buckets
logs_volume_buckets_distributed
marketing_conversions_preaggregated
marketing_costs_preaggregated
marketing_touchpoints_preaggregated
message_assets
message_assets_data
message_assets_mv
metric_attributes
metric_samples
metric_samples1
metric_series
metric_series1
metrics
metrics1
metrics1_to_metric_attributes
metrics1_to_resource_attributes
metrics_kafka_metrics
ops_query_log_archive_mv
partitioned_sharded_posthog_document_embeddings
performance_events
performance_events_mv
person
person_distinct_id
person_distinct_id2
person_distinct_id2_mv
person_distinct_id_mv
person_distinct_id_overrides
person_distinct_id_overrides_dict
person_distinct_id_overrides_mv
person_mv
person_overrides
person_overrides_dict
person_overrides_mv
person_static_cohort
persons_batch_export
persons_batch_export_backfill
pg_embeddings
plugin_log_entries
plugin_log_entries_mv
posthog_document_embeddings_kafka_to_buffer_mv
posthog_document_embeddings_text_embedding_3_large_3072_mv
posthog_document_embeddings_text_embedding_3_small_1536_mv
posthog_document_embeddings_union_view
preaggregation_results
precalculated_events
precalculated_events_mv
precalculated_person_properties
precalculated_person_properties_mv
property_definitions
property_values
property_values_distributed
property_values_mv
query_log_archive
query_log_archive_buffer
query_log_archive_v2
raw_error_tracking_fingerprint_issue_state
raw_sessions
raw_sessions_mv
raw_sessions_v
raw_sessions_v3
raw_sessions_v3_v
session_replay_embeddings
session_replay_events
session_replay_events_mv
session_replay_features
session_replay_features_mv
sessions
sessions_mv
sessions_v
sharded_ai_events
sharded_app_metrics
sharded_app_metrics2
sharded_billing_usage_records
sharded_conversion_goal_attributed_preaggregated
sharded_distinct_id_usage
sharded_events
sharded_events_json
sharded_events_recent
sharded_experiment_exposures_preaggregated
sharded_experiment_metric_events_preaggregated
sharded_flag_evaluations
sharded_heatmaps
sharded_ingestion_warnings
sharded_log_entries
sharded_marketing_conversions_preaggregated
sharded_marketing_costs_preaggregated
sharded_marketing_touchpoints_preaggregated
sharded_performance_events
sharded_posthog_document_embeddings_buffer
sharded_posthog_document_embeddings_text_embedding_3_large_3072
sharded_posthog_document_embeddings_text_embedding_3_small_1536
sharded_preaggregation_results
sharded_precalculated_events
sharded_precalculated_person_properties
sharded_query_log_archive
sharded_query_log_archive_old
sharded_raw_sessions
sharded_raw_sessions_v3
sharded_session_replay_embeddings
sharded_session_replay_events
sharded_session_replay_features
sharded_sessions
sharded_tophog
sharded_usage_report_events_preagg
sharded_web_bot_definition
sharded_web_bounces_dimensional_preaggregated
sharded_web_goals_preaggregated
sharded_web_overview_preaggregated
sharded_web_stats_dimensional_preaggregated
sharded_web_stats_frustration_preaggregated
sharded_web_stats_paths_preaggregated
sharded_web_stats_paths_preaggregated_pathkey
sharded_web_stats_preaggregated
sharded_web_vitals_paths_preaggregated
tophog
tophog_mv
tophog_ws_mv
trace_attributes
trace_attributes2
trace_attributes_distributed
trace_span_to_attributes
trace_span_to_attributes2
trace_span_to_resource_attributes
trace_span_to_resource_attributes2
trace_span_to_span_attributes
trace_span_to_span_attributes2
trace_spans
trace_spans_distributed
trace_spans_kafka_metrics
trace_spans_to_kafka_metrics_mv
usage_report_events_preagg
usage_report_events_preagg_mv
web_bot_definition
web_bot_definition_dict
web_bounces_dimensional_preaggregated
web_goals_preaggregated
web_overview_preaggregated
web_pre_aggregated_bounces
web_pre_aggregated_bounces_staging
web_pre_aggregated_stats
web_pre_aggregated_stats_staging
web_pre_aggregated_teams
web_pre_aggregated_teams_dict
web_stats_dimensional_preaggregated
web_stats_frustration_preaggregated
web_stats_paths_preaggregated
web_stats_paths_preaggregated_pathkey
web_stats_preaggregated
web_vitals_paths_preaggregated
writable_app_metrics
writable_app_metrics2
writable_billing_usage_records
writable_cohort_membership
writable_distinct_id_usage
writable_duplicate_events
writable_error_tracking_fingerprint_issue_state
writable_error_tracking_issue_fingerprint_overrides
writable_events
writable_events_dead_letter_queue
writable_events_json
writable_events_recent
writable_flag_evaluations
writable_groups
writable_heatmaps
writable_ingestion_warnings
writable_log_entries
writable_logs34
writable_person
writable_person_distinct_id2
writable_person_distinct_id_overrides
writable_plugin_log_entries
writable_posthog_document_embeddings
writable_posthog_document_embeddings_buffer
writable_posthog_document_embeddings_text_embedding_3_large_3072
writable_posthog_document_embeddings_text_embedding_3_small_1536
writable_precalculated_events
writable_precalculated_person_properties
writable_query_log_archive
writable_raw_sessions
writable_raw_sessions_v3
writable_session_replay_embeddings
writable_session_replay_events
writable_session_replay_features
writable_sessions
writable_tophog
writable_usage_report_events_preagg
writeable_performance_events
== events schema ==
uuid	UUID					
event	String					
properties	String				ZSTD(3)	
timestamp	DateTime64(6, \'UTC\')					
team_id	Int64					
distinct_id	String					
elements_chain	String					
created_at	DateTime64(6, \'UTC\')					
person_id	UUID					
person_created_at	DateTime64(3)					
person_properties	String				ZSTD(3)	
group0_properties	String				ZSTD(3)	
group1_properties	String				ZSTD(3)	
group2_properties	String				ZSTD(3)	
group3_properties	String				ZSTD(3)	
group4_properties	String				ZSTD(3)	
group0_created_at	DateTime64(3)					
group1_created_at	DateTime64(3)					
group2_created_at	DateTime64(3)					
group3_created_at	DateTime64(3)					
group4_created_at	DateTime64(3)					
person_mode	Enum8(\'full\' = 0, \'propertyless\' = 1, \'force_upgrade\' = 2)					
historical_migration	Bool					
dmat_string_0	Nullable(String)					
dmat_string_1	Nullable(String)					
dmat_string_2	Nullable(String)					
dmat_string_3	Nullable(String)					
dmat_string_4	Nullable(String)					
dmat_string_5	Nullable(String)					
dmat_string_6	Nullable(String)					
dmat_string_7	Nullable(String)					
dmat_string_8	Nullable(String)					
dmat_string_9	Nullable(String)					
$group_0	String			column_materializer::$group_0		
$group_1	String			column_materializer::$group_1		
$group_2	String			column_materializer::$group_2		
$group_3	String			column_materializer::$group_3		
$group_4	String			column_materializer::$group_4		
$window_id	String			column_materializer::$window_id		
$session_id	String			column_materializer::$session_id		
== events engine ==
events	Distributed
events_json_mv	MaterializedView
kafka_events_json	Kafka
person	ReplicatedReplacingMergeTree
person_distinct_id2	ReplicatedReplacingMergeTree
sharded_events	ReplicatedReplacingMergeTree
writable_events	Distributed
== kafka engine settings ==
kafka_ai_events_json	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_ai_events_json\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_app_metrics	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_app_metrics\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_app_metrics2	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_app_metrics2\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_app_metrics2_ws	Kafka(warpstream_ingestion, kafka_topic_list = \'clickhouse_app_metrics2\', kafka_group_name = \'clickhouse_app_metrics2_ws\', kafka_format = \'JSONEachRow\')
kafka_billing_usage_records	Kafka(warpstream_shared, kafka_topic_list = \'clickhouse_billing_usage_records\', kafka_group_name = \'clickhouse_billing_usage_records\', kafka_format = \'JSONEachRow\') SETTINGS date_time_input_format = \'best_effort\'
kafka_cohort_membership	Kafka(msk_cluster, kafka_topic_list = \'cohort_membership_changed\', kafka_group_name = \'clickhouse_cohort_membership_changed\', kafka_format = \'JSONEachRow\')
kafka_distinct_id_usage	Kafka(warpstream_ingestion, kafka_topic_list = \'distinct_id_usage_events_json\', kafka_group_name = \'clickhouse_distinct_id_usage\', kafka_format = \'JSONEachRow\') SETTINGS kafka_skip_broken_messages = 100
kafka_duplicate_events	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_ingestion_events_duplicates\', kafka_group_name = \'clickhouse_duplicate_events\', kafka_format = \'JSONEachRow\')
kafka_error_tracking_fingerprint_issue_state	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_error_tracking_fingerprint_issue_state\', kafka_group_name = \'clickhouse-error-tracking-fingerprint-issue-state\', kafka_format = \'JSONEachRow\')
kafka_error_tracking_issue_fingerprint_overrides	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_error_tracking_issue_fingerprint\', kafka_group_name = \'clickhouse-error-tracking-issue-fingerprint-overrides\', kafka_format = \'JSONEachRow\')
kafka_events_dead_letter_queue	Kafka(msk_cluster, kafka_topic_list = \'events_dead_letter_queue\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\') SETTINGS kafka_skip_broken_messages = 1000
kafka_events_json	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_events_json\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\') SETTINGS kafka_skip_broken_messages = 100
kafka_events_json_native_json	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_events_json\', kafka_group_name = \'clickhouse_events_json_native_json\', kafka_format = \'JSONEachRow\') SETTINGS kafka_skip_broken_messages = 100
kafka_flag_evaluations	Kafka(warpstream_ingestion, kafka_topic_list = \'clickhouse_flag_evaluations\', kafka_group_name = \'clickhouse_flag_evaluations\', kafka_format = \'JSONEachRow\') SETTINGS kafka_skip_broken_messages = 100
kafka_groups	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_groups\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_heatmaps	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_heatmap_events\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_hog_invocation_results	Kafka(warpstream_cyclotron, kafka_topic_list = \'clickhouse_hog_invocation_results\', kafka_group_name = \'clickhouse_hog_invocation_results\', kafka_format = \'JSONEachRow\') SETTINGS kafka_skip_broken_messages = 100
kafka_ingestion_warnings	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_ingestion_warnings\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_ingestion_warnings_v2	Kafka(warpstream_ingestion, kafka_topic_list = \'clickhouse_ingestion_warnings\', kafka_group_name = \'clickhouse_ingestion_warnings_v2\', kafka_format = \'JSONEachRow\')
kafka_log_entries_v3	Kafka(msk_cluster, kafka_topic_list = \'log_entries\', kafka_group_name = \'clickhouse_log_entries\', kafka_format = \'JSONEachRow\') SETTINGS kafka_skip_broken_messages = 100
kafka_log_entries_ws	Kafka(warpstream_ingestion, kafka_topic_list = \'log_entries\', kafka_group_name = \'clickhouse_log_entries_ws\', kafka_format = \'JSONEachRow\') SETTINGS kafka_skip_broken_messages = 100
kafka_logs_avro	Kafka(warpstream_logs, kafka_topic_list = \'clickhouse_logs\', kafka_group_name = \'clickhouse-logs-avro-new\', kafka_format = \'Avro\') SETTINGS kafka_skip_broken_messages = 100, kafka_num_consumers = 8, kafka_poll_timeout_ms = 3000, kafka_poll_max_batch_size = 1000, kafka_thread_per_consumer = 1, input_format_avro_allow_missing_fields = 1
kafka_message_assets	Kafka(warpstream_cyclotron, kafka_topic_list = \'clickhouse_message_assets\', kafka_group_name = \'clickhouse_message_assets\', kafka_format = \'JSONEachRow\') SETTINGS kafka_skip_broken_messages = 100
kafka_metrics_avro	Kafka(warpstream_metrics, kafka_topic_list = \'clickhouse_metrics\', kafka_group_name = \'clickhouse-metrics-avro-new\', kafka_format = \'Avro\') SETTINGS kafka_skip_broken_messages = 100, kafka_thread_per_consumer = 1, kafka_num_consumers = 8, kafka_poll_timeout_ms = 3000, kafka_poll_max_batch_size = 1000
kafka_performance_events	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_performance_events\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_person	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_person\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_person_distinct_id	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_person_unique_id\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_person_distinct_id2	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_person_distinct_id\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_person_distinct_id_overrides	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_person_distinct_id\', kafka_group_name = \'clickhouse-person-distinct-id-overrides\', kafka_format = \'JSONEachRow\')
kafka_person_overrides	Kafka(\'kafka\', \'clickhouse_person_override\', \'clickhouse-person-overrides\', \'JSONEachRow\')
kafka_plugin_log_entries	Kafka(msk_cluster, kafka_topic_list = \'plugin_log_entries\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_posthog_document_embeddings	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_document_embeddings\', kafka_group_name = \'clickhouse_document_embeddings\', kafka_format = \'JSONEachRow\')
kafka_precalculated_events	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_prefiltered_events\', kafka_group_name = \'clickhouse_prefiltered_events\', kafka_format = \'JSONEachRow\') SETTINGS kafka_max_block_size = 1000000, kafka_poll_max_batch_size = 100000, kafka_poll_timeout_ms = 1000, kafka_flush_interval_ms = 7500, kafka_skip_broken_messages = 100, kafka_num_consumers = 1
kafka_precalculated_person_properties	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_precalculated_person_properties\', kafka_group_name = \'clickhouse_precalculated_person_properties\', kafka_format = \'JSONEachRow\') SETTINGS kafka_max_block_size = 1000000, kafka_poll_max_batch_size = 100000, kafka_poll_timeout_ms = 1000, kafka_flush_interval_ms = 7500, kafka_skip_broken_messages = 100, kafka_num_consumers = 1
kafka_property_values	Kafka(warpstream_ingestion, kafka_topic_list = \'clickhouse_property_values\', kafka_group_name = \'clickhouse_property_values\', kafka_format = \'JSONEachRow\') SETTINGS kafka_num_consumers = 8, kafka_thread_per_consumer = 1
kafka_session_replay_events	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_session_replay_events\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_session_replay_features	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_session_replay_features\', kafka_group_name = \'group1\', kafka_format = \'JSONEachRow\')
kafka_tophog	Kafka(msk_cluster, kafka_topic_list = \'clickhouse_tophog\', kafka_group_name = \'clickhouse_tophog\', kafka_format = \'JSONEachRow\') SETTINGS date_time_input_format = \'best_effort\', kafka_skip_broken_messages = 100
kafka_tophog_ws	Kafka(warpstream_ingestion, kafka_topic_list = \'clickhouse_tophog\', kafka_group_name = \'clickhouse_tophog_ws\', kafka_format = \'JSONEachRow\') SETTINGS date_time_input_format = \'best_effort\', kafka_skip_broken_messages = 100
kafka_trace_spans_avro	Kafka(warpstream_traces, kafka_topic_list = \'clickhouse_traces\', kafka_group_name = \'clickhouse-traces-avro\', kafka_format = \'Avro\') SETTINGS kafka_skip_broken_messages = 100, kafka_thread_per_consumer = 1, kafka_num_consumers = 8, kafka_poll_timeout_ms = 3000, kafka_poll_max_batch_size = 1000
kafka_usage_report_events_preagg	Kafka(warpstream_ingestion, kafka_topic_list = \'clickhouse_events_json\', kafka_group_name = \'clickhouse_usage_report_events_preagg\', kafka_format = \'JSONEachRow\') SETTINGS kafka_skip_broken_messages = 100, kafka_thread_per_consumer = 1, kafka_num_consumers = 1
== teams ==
1|phc_ngnuUL6gSNY6fw2Nur4xxRpecCS9KnUpEapTDvDtpfPT|Default project
