0
0
mirror of https://github.com/PostHog/posthog.git synced 2024-11-28 09:16:49 +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
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