mirrors/posthog
0
0
Fork 0
mirror of https://github.com/PostHog/posthog.git synced 2024-11-24 18:07:17 +01:00
Code Issues Releases Activity
44bfcffca4
posthog/ee/idl/event.avro

32 lines
530 B
Plaintext
Raw Normal View History

Publish events to Kafka for consumption (#1644) * Publish events to Kafka for consumption * Commit avro idl's for event schemas * convert client to use github.com/dpkp/kafka-python * events loaded into clickhouse from Kafka * remove cruft * Publish events to Kafka for consumption * convert client to use github.com/dpkp/kafka-python * remove cruft * include kafka migrations * bugfixes for migrations * use constants for consistency * wrap up local migrations * small fixes * tune ups
2020-09-16 05:04:38 +02:00
{
"namespace": "com.posthog.ee",
"name": "event",
"type": "record",
"fields" : [
{
"name" : "event",
"type" : "string"
},
{
"name" : "team_id",
"type" : "long"
},
{
"name" : "properties",
"type" : "map",
"values" : "string"
},
{
"name": "timestamp",
"type": "string"
},
{
"name": "distinct_id",
"type": "string"
},
{
Clickhouse Elements Dedup (based on master) (#1698) * Use ReplacingMergeTree for elements, remove element_groups and use elements_hash as a virtual "pk" * remove unused ELEMENT_GROUP_TABLE_SQL * merge fixes * use redis cache to avoid writing duplicate elements to clickhouse * move fakeredis to requirements.txt * add team_id to cache key * remove elements_group kafka table references * add elements_hash to clickhouse element serializer * fix cache key * rename few keys * add test runner to ease pycharm dev * fix a some mypy errors * remove typo Co-authored-by: Eric <eeoneric@gmail.com>
2020-09-24 12:47:28 +02:00
"name": "elements_hash",
Publish events to Kafka for consumption (#1644) * Publish events to Kafka for consumption * Commit avro idl's for event schemas * convert client to use github.com/dpkp/kafka-python * events loaded into clickhouse from Kafka * remove cruft * Publish events to Kafka for consumption * convert client to use github.com/dpkp/kafka-python * remove cruft * include kafka migrations * bugfixes for migrations * use constants for consistency * wrap up local migrations * small fixes * tune ups
2020-09-16 05:04:38 +02:00
"type": "string"
}
]
}
Copy Permalink