posthog/clickhouse/test/test_person_overrides.py
sync_execute(KAFKA_PERSON_OVERRIDES_TABLE_SQL)
    sync_execute(PERSON_OVERRIDES_CREATE_MATERIALIZED_VIEW_SQL)
    producer = KafkaProducer(bootstrap_servers=KAFKA_HOSTS)
    try:
        old_person_id = uuid4()
        override_person_id = uuid4()
        oldest_event_string = "2020-01-01 00:00:00"
        oldest_event = datetime.fromisoformat(oldest_event_string).replace(tzinfo=pytz.UTC)
        merged_at_string = "2020-01-02 00:00:00"
        merged_at = datetime.fromisoformat(merged_at_string).replace(tzinfo=pytz.UTC)
        message = {
            "team_id": 1,
            "old_person_id": str(old_person_id),
            "override_person_id": str(override_person_id),
            "oldest_event": oldest_event_string,
            "merged_at": merged_at_string,
            "version": 2,
        }
        future = producer.send(
            topic=KAFKA_PERSON_OVERRIDE,
            key=str(uuid4()).encode("utf-8"),
            value=json.dumps(message).encode("utf-8"),
        )
        future.get(timeout=5)  
        
        results = []
        for _ in range(5):