Техническое задание: Отладка и финальная настройка Kafka

Контекст проекта

Существует работающий проект на Python с использованием фреймворка FastAPI. Сервисы развернуты в Docker-контейнерах. В проект уже интегрирован Apache Kafka, однако в его работе обнаружена ошибка, требующая устранения.

Основная цель

Найти и исправить существующий баг, мешающий корректной работе с очередями сообщений. Довести текущую реализацию до полностью рабочего состояния.

Ключевые задачи

• Провести диагностику текущей конфигурации и кода интеграции с Kafka.
• Выявить причину нестабильной работы (проблемы с отправкой, получением или обработкой сообщений).
• Обеспечить надежную работу продюсеров (отправка сообщений).
• Настроить корректную работу консьюмеров (получение и обработка сообщений).
• Убедиться в совместимости и стабильности работы всех компонентов в Docker-окружении.
• При необходимости, оптимизировать настройки для повышения надежности.

Требования к реализации

• Работа ведется с существующей кодовой базой на Python.
• Архитектура микросервисов на FastAPI должна быть сохранена.
• Решение должно быть готово к работе в production-среде.
• Исполнителю будет предоставлен доступ к репозиторию и документации для анализа.

Ожидаемый результат

Полностью отлаженная и стабильно работающая система обмена сообщениями между сервисами через Apache Kafka. Готовность к промышленной эксплуатации.