Срочно Kafka Consumer с обработкой последнего сообщения
Скрипты и боты
Бюджет: 10000 руб.
Срочно
Что нужно реализовать:
Kafka consumer на Java:
Подписывается на заданный топик Kafka.
При старте определяет текущее максимальное смещение в топике.
Считывает последнее сообщение (смещение - 1).
После этого начинает слушать и обрабатывать новые сообщения в реальном времени.
Docker окружение:
Использовать docker-compose для поднятия Kafka.
Контейнер с Java-приложением (или локальный запуск).
Тесты (JUnit):
Проверить корректность работы consumer:
Отправить тестовые сообщения в Kafka.
Убедиться, что consumer после рестарта корректно считывает последнее отправленное сообщение и продолжает работу с новыми.
Использовать интеграционные тесты, взаимодействующие с реальной Kafka из Docker.
Ключевые особенности:
Kafka consumer должен самостоятельно определять позицию смещения при запуске.
Работать с manual commit или seek, чтобы контролировать смещения.
После перезапуска не пропускать последнее сообщение, а начать с него.