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

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

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

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

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

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

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

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

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

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

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