0
0
mirror of https://github.com/PostHog/posthog.git synced 2024-11-28 09:16:49 +01:00
posthog/ee/kafka_client/topics.py
James Greenhill b64673ca4e
wire up the length to the proto message (#2089)
* wire up the length to the proto message

* we are so deep into the proto weeds we are using proto private methods
2020-10-28 17:41:13 -07:00

8 lines
286 B
Python

KAFKA_EVENTS = "clickhouse_events_proto"
KAFKA_ELEMENTS = "clickhouse_elements"
KAFKA_PERSON = "clickhouse_person"
KAFKA_PERSON_UNIQUE_ID = "clickhouse_person_unique_id"
KAFKA_SESSION_RECORDING_EVENTS = "clickhouse_session_recording_events"
KAFKA_EVENTS_WAL = "events_write_ahead_log"