0
0
mirror of https://github.com/PostHog/posthog.git synced 2024-12-01 04:12:23 +01:00
posthog/ee/kafka_client
Yakko Majuri 7b50b0e35f
Events dead letter queue CH table (#6193)
* events dead letter queue CH table

* format

* update schemas

* also store raw payload

* better naming

* make table name more clear

* wip better testing

* remove unused imports

* remove kafka test

* prevent non null test from running on CH migrations

* add kafka testing

* minor tests cleanup

* test naive longer sleep

* make test end-to-end

* address review

* update ttl, format

* refactor delay func, address review
2021-10-07 08:30:13 +00:00
..
test Create Kafka consumer and write tests for consumer and producer (#6170) 2021-10-01 09:43:50 +01:00
__init__.py Create a write ahead log for cloud event processing (#1962) 2020-10-21 20:35:07 +02:00
client.py Create Kafka consumer and write tests for consumer and producer (#6170) 2021-10-01 09:43:50 +01:00
helper.py Create Kafka consumer and write tests for consumer and producer (#6170) 2021-10-01 09:43:50 +01:00
topics.py Events dead letter queue CH table (#6193) 2021-10-07 08:30:13 +00:00