Review points 1, 2, 3

[LuchnikKek]

1. Удалён лишний etl/src/consumer.py
2. Добавлен конфиг через BaseSettings
3. Создан BaseService с методом .send(). Метод валидирует сообщение по схеме self.schema и если оно валидно - пишет его в self.topic.

Ну и добавил:

• базовую схему (по аналогии с базовым event'ом в ETL), содержащую UUID пользователя и время события
• обработчик ValidationError, чтобы 500 не плевался
• подстановку текущего времени, если time не представлено в отправленном json (не уверен, что не было, мб поломал и починил с: )