Karl-Aksel Puulmann 78a787bc3b Create and populate person_distinct_id2 table, add versioning to person_distinct_id (#7576) ... * Migration to add version to person_distinct_id * Update plugin-server type * Use queueMessages instead of for loops * Update distinct id versions in postgres * Add commented out new query * Add person_distinct_id2 table setup/migration This will be used for more efficient person_distinct_id queries * Avoid sharding person_distinct_id2 on cloud * Write to new distinct ids topic * Attempt to use version in tests * Tests attempt 2 * Fixup version - dont send with all messages * Flush kafka more frequently * Actually fix tests * Add another await * Add partition to person_distinct_id2 table		2021-12-08 16:47:57 +02: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	Add retries to kafka producer to mitigate event loss (#6638)	2021-10-25 22:40:32 -07:00
helper.py	Create Kafka consumer and write tests for consumer and producer (#6170)	2021-10-01 09:43:50 +01:00
topics.py	Create and populate person_distinct_id2 table, add versioning to person_distinct_id (#7576)	2021-12-08 16:47:57 +02:00