Домашнее задание: создание системы обработки сообщений с использованием Apache Kafka

Задание: Разработать приложение, которое будет отправлять и обрабатывать сообщения о погодных условиях в реальном времени, используя Apache Kafka. Это домашнее задание из курса по инфраструктуре больших данных. Сложных наворотов не требуется.

Стек: Python, Apache Kafka (использовать библиотеку kafka-python), БД SQLite или другая легкая БД, API OpenWeatherMap.

Что ожидаю получить: папку со всеми необходимыми по условию задачи файлами и README, готовую к публикации в репозитории; выгрузку с сохраненными данными о погоде в JSON формате.

Полное условие задания и критерии оценивания - в прикрепленном файле.

Обратите внимание на описание критериев оценки - там могут быть дополнительные условия. Ориентируйтесь на условия для получения максимального балла.